fix(pubsub): clear interval on error

License: MIT Signed-off-by: Alan Shaw <alan@tableflip.io>
ipfs-inactive · May 17, 2018 · d074e13 · d074e13
1 parent f5ccada
commit d074e13
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/js/src/pubsub.js b/js/src/pubsub.js
@@ -21,6 +21,7 @@ function waitForPeers (ipfs, topic, peersToWait, callback) {
   const i = setInterval(() => {
     ipfs.pubsub.peers(topic, (err, peers) => {
       if (err) {
+        clearInterval(i)
         return callback(err)
       }