fix: for when peerinfo resolves to undefined

libp2p · Mar 12, 2018 · 6f98b0c · 6f98b0c
1 parent ae6b52e
commit 6f98b0c
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/src/observer.js b/src/observer.js
@@ -30,8 +30,10 @@ module.exports = (swtch) => {
 
   function willObserve (peerInfo, transport, protocol, direction, bufferLength) {
     peerInfo.then((pi) => {
-      const peerId = pi.id.toB58String()
-      setImmediate(() => observer.emit('message', peerId, transport, protocol, direction, bufferLength))
+      if (pi) {
+        const peerId = pi.id.toB58String()
+        setImmediate(() => observer.emit('message', peerId, transport, protocol, direction, bufferLength))
+      }
     })
   }
 }