fix: _dialPeer always calls back

libp2p · Jul 6, 2017 · bccffd6 · bccffd6
1 parent d1b10cf
commit bccffd6
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/src/index.js b/src/index.js
@@ -67,12 +67,13 @@ class FloodSub extends EventEmitter {
     // If already have a PubSub conn, ignore
     const peer = this.peers.get(idB58Str)
     if (peer && peer.isConnected) {
-      return
+      return callback()
     }
 
     this.libp2p.dial(peerInfo, multicodec, (err, conn) => {
       if (err) {
-        return log.err(err)
+        log.err(err)
+        return callback()
       }
 
       this._onDial(peerInfo, conn, callback)