pubsub.unsubscribe without handler reference

SPEC/PUBSUB.md

@@ -50,7 +50,9 @@ A great source of [examples][] can be found in the tests for this API.
 
 If no `callback` is passed, a [promise][] is returned.
 
-This works like `EventEmitter.removeListener`, as that only the `handler` passed to a `subscribe` call before is removed from listening. The underlying subscription will only be canceled once all listeners for a topic have been removed.
+If the `topic` and `handler` are provided, the `handler` will no longer receive updates for the `topic`. This behaves like `EventEmitter.removeListener`. If the `handler` is not equivalent to the `handler` provided on `subscribe`, no action will be taken.
+
+If **only** the `topic` param is provided, unsubscribe will remove **all** handlers for the `topic`. This behaves like `EventEmitter.remoteAllListeners`. Use this if you would like to no longer receive any updates for the `topic`.
 
 **Example:**
 
@@ -78,6 +80,25 @@ ipfs.pubsub.subscribe(topic, receiveMsg, (err) => {
 })
 ```
 
+Or removing all listeners: 
+```JavaScript
+const topic = 'fruit-of-the-day'
+const receiveMsg = (msg) => console.log(msg.toString())
+
+ipfs.pubsub.subscribe(topic, receiveMsg, (err) => {
+  if (err) {
+    return console.error(`failed to subscribe to ${topic}`, err)
+  }
+
+  console.log(`subscribed to ${topic}`)
+
+  setTimeout(() => {
+    // Will unsubscribe ALL handlers for the given topic
+    ipfs.pubsub.unsubscribe(topic);
+  }, 1000)
+})
+```
+
 A great source of [examples][] can be found in the tests for this API.
 
 #### `pubsub.publish`

src/pubsub/unsubscribe.js

@@ -57,5 +57,26 @@ module.exports = (createCommon, options) => {
         )
       })
     })
+
+    it('should subscribe 10 handlers and unsunscribe once with no reference to the handlers', (done) => {
+      const count = 10
+      const someTopic = getTopic()
+
+      timesSeries(count, (_, cb) => {
+        const handler = (msg) => {}
+        ipfs.pubsub.subscribe(someTopic, handler, (err) => cb(err))
+      }, (err) => {
+        expect(err).to.not.exist()
+        ipfs.pubsub.unsubscribe(someTopic)
+        setTimeout(() => {
+          // Assert unsubscribe worked
+          ipfs.pubsub.ls((err, topics) => {
+            expect(err).to.not.exist()
+            expect(topics).to.eql([])
+            done()
+          })
+        }, 500)
+      })
+    })
   })
 }