feat: add listeners

src/index.js

@@ -258,15 +258,21 @@ class FloodSub extends BaseProtocol {
    * Subscribe to the given topic(s).
    * @override
    * @param {Array<string>|string} topics
+   * @param {function} [handler]
    * @returns {void}
    */
-  subscribe (topics) {
+  subscribe (topics, handler) {
     if (!this.started) {
       throw new Error('FloodSub is not started')
     }
 
     topics = ensureArray(topics)
-    topics.forEach((topic) => this.subscriptions.add(topic))
+    topics.forEach((topic) => {
+      this.subscriptions.add(topic)
+
+      // Bind provider handler
+      handler && this.on(topic, handler)
+    })
 
     this.peers.forEach((_, id) => this._sendSubscriptions(id, topics, true))
   }
@@ -275,16 +281,24 @@ class FloodSub extends BaseProtocol {
    * Unsubscribe from the given topic(s).
    * @override
    * @param {Array<string>|string} topics
+   * @param {function} [handler]
    * @returns {void}
    */
-  unsubscribe (topics) {
+  unsubscribe (topics, handler) {
     if (!this.started) {
       throw new Error('FloodSub is not started')
     }
 
     topics = ensureArray(topics)
 
-    topics.forEach((topic) => this.subscriptions.delete(topic))
+    topics.forEach((topic) => {
+      this.subscriptions.delete(topic)
+
+      // Remove bind handlers
+      if (!handler) {
+
+      }
+    })
 
     this.peers.forEach((_, id) => this._sendSubscriptions(id, topics, false))
   }