fix: pubsub subscribe call with options

License: MIT Signed-off-by: Alan Shaw <alan@tableflip.io>
ipfs-inactive · May 9, 2018 · c43f8bc · c43f8bc
1 parent 4c13425
commit c43f8bc
Showing 1 changed file with 10 additions and 6 deletions.
diff --git a/js/src/pubsub.js b/js/src/pubsub.js
@@ -138,7 +138,9 @@ module.exports = (common) => {
             expect(msg).to.have.property('topicIDs').eql([topic])
             expect(msg).to.have.property('from', ipfs1.peerId.id)
 
-            ipfs1.pubsub.unsubscribe(topic, handler, () => {
+            ipfs1.pubsub.unsubscribe(topic, handler, (err) => {
+              expect(err).to.not.exist()
+
               ipfs1.pubsub.ls((err, topics) => {
                 expect(err).to.not.exist()
                 expect(topics).to.be.empty()
@@ -164,7 +166,9 @@ module.exports = (common) => {
             expect(msg).to.have.property('topicIDs').eql([topic])
             expect(msg).to.have.property('from', ipfs1.peerId.id)
 
-            ipfs1.pubsub.unsubscribe(topic, handler, () => {
+            ipfs1.pubsub.unsubscribe(topic, handler, (err) => {
+              expect(err).to.not.exist()
+
               ipfs1.pubsub.ls((err, topics) => {
                 expect(err).to.not.exist()
                 expect(topics).to.be.empty()
@@ -190,7 +194,9 @@ module.exports = (common) => {
             expect(msg).to.have.property('topicIDs').eql([topic])
             expect(msg).to.have.property('from', ipfs1.peerId.id)
 
-            ipfs1.pubsub.unsubscribe(topic, handler, () => {
+            ipfs1.pubsub.unsubscribe(topic, handler, (err) => {
+              expect(err).to.not.exist()
+
               ipfs1.pubsub.ls((err, topics) => {
                 expect(err).to.not.exist()
                 expect(topics).to.be.empty()
@@ -251,9 +257,7 @@ module.exports = (common) => {
             ipfs1.pubsub.unsubscribe(topic, handler, check)
           }
 
-          ipfs1.pubsub.subscribe(topic, {
-            discover: true
-          }, handler, (err) => {
+          ipfs1.pubsub.subscribe(topic, handler, { discover: true }, (err) => {
             expect(err).to.not.exist()
             ipfs1.pubsub.publish(topic, Buffer.from('hi'), check)
           })