fix: preventing uncaught error. Fixes #263

libp2p · Jun 8, 2018 · 9189844 · 9189844
1 parent c0eae1e
commit 9189844
Showing 1 changed file with 11 additions and 2 deletions.
diff --git a/src/dial.js b/src/dial.js
@@ -77,7 +77,10 @@ function dial (swtch) {
         // 3. update the peerInfo that is already stored in the conn
       }
 
-      openConnInMuxedConn(muxer, (conn) => {
+      openConnInMuxedConn(muxer, (err, conn) => {
+        if (err) {
+          return callback(err)
+        }
         protocolHandshake(conn, protocol, callback)
       })
     }
@@ -208,7 +211,13 @@ function dial (swtch) {
     }
 
     function openConnInMuxedConn (muxer, cb) {
-      cb(muxer.newStream())
+      let s
+      try {
+        s = muxer.newStream()
+      } catch (err) {
+        return cb(err)
+      }
+      cb(null, s)
     }
 
     function protocolHandshake (conn, protocol, cb) {