feat: use pull-mplex (renamed from pull-plex)

libp2p · Apr 15, 2018 · 9615da1 · 9615da1
1 parent 5235823
commit 9615da1
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 4 deletions.
diff --git a/package.json b/package.json
@@ -42,7 +42,7 @@
     "async": "^2.6.0",
     "debug": "^3.1.0",
     "pull-abortable": "^4.1.1",
-    "pull-plex": "~0.0.1",
+    "pull-mplex": "~0.0.1",
     "pull-stream": "^3.6.7"
   },
   "contributors": [

diff --git a/src/index.js b/src/index.js
@@ -2,7 +2,7 @@
 
 const MULTIPLEX_CODEC = require('./codec')
 const pull = require('pull-stream')
-const Mplex = require('pull-plex')
+const Mplex = require('pull-mplex')
 const abortable = require('pull-abortable')
 const Muxer = require('./muxer')
 

diff --git a/src/muxer.js b/src/muxer.js
@@ -24,7 +24,7 @@ class MultiplexMuxer extends EventEmitter {
 
     multiplex.on('stream', (stream) => {
       // install default error handler so that it doesn't throw
-      stream.once('error', (err) => {
+      stream.on('error', (err) => {
         log.err('receiver stream errored', err)
       })
       this.emit('stream', new Connection(stream, this.conn))
@@ -40,7 +40,6 @@ class MultiplexMuxer extends EventEmitter {
       log.err('initiator stream errored', err)
     })
     const conn = new Connection(stream, this.conn)
-    stream.openChan()
     setImmediate(() => callback(null, conn))
     return conn
   }