mirror of
https://github.com/fluencelabs/js-libp2p-interfaces
synced 2025-04-24 20:02:20 +00:00
feat(api): update the interface usage from dial to dialer and listen to listener
This commit is contained in:
parent
99d07adfac
commit
5069679163
@ -31,8 +31,8 @@ module.exports = (common) => {
|
||||
|
||||
it('Open a stream from the dialer', (done) => {
|
||||
const p = pair()
|
||||
const dialer = muxer.dial(p[0])
|
||||
const listener = muxer.listen(p[1])
|
||||
const dialer = muxer.dialer(p[0])
|
||||
const listener = muxer.listener(p[1])
|
||||
|
||||
expect(4).checks(done)
|
||||
|
||||
@ -50,8 +50,8 @@ module.exports = (common) => {
|
||||
|
||||
it('Open a stream from the listener', (done) => {
|
||||
const p = pair()
|
||||
const dialer = muxer.dial(p[0])
|
||||
const listener = muxer.listen(p[1])
|
||||
const dialer = muxer.dialer(p[0])
|
||||
const listener = muxer.listener(p[1])
|
||||
|
||||
expect(4).check(done)
|
||||
|
||||
@ -69,8 +69,8 @@ module.exports = (common) => {
|
||||
|
||||
it('Open a stream on both sides', (done) => {
|
||||
const p = pair()
|
||||
const dialer = muxer.dial(p[0])
|
||||
const listener = muxer.listen(p[1])
|
||||
const dialer = muxer.dialer(p[0])
|
||||
const listener = muxer.listener(p[1])
|
||||
|
||||
expect(8).check(done)
|
||||
|
||||
@ -98,8 +98,8 @@ module.exports = (common) => {
|
||||
|
||||
it('Open a stream on one side, write, open a stream in the other side', (done) => {
|
||||
const p = pair()
|
||||
const dialer = muxer.dial(p[0])
|
||||
const listener = muxer.listen(p[1])
|
||||
const dialer = muxer.dialer(p[0])
|
||||
const listener = muxer.listener(p[1])
|
||||
|
||||
expect(6).check(done)
|
||||
|
||||
|
@ -17,8 +17,8 @@ module.exports = (muxer, nStreams, nMsg, done, limit) => {
|
||||
|
||||
const msg = 'simple msg'
|
||||
|
||||
const listener = muxer.listen(listenerSocket)
|
||||
const dialer = muxer.dial(dialerSocket)
|
||||
const listener = muxer.listener(listenerSocket)
|
||||
const dialer = muxer.dialer(dialerSocket)
|
||||
|
||||
listener.on('stream', (stream) => {
|
||||
expect(stream).to.exist
|
||||
|
Loading…
x
Reference in New Issue
Block a user