diff --git a/js/src/pubsub.js b/js/src/pubsub.js
index a877073e..fc97c522 100644
--- 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)
       }