feat: add offListener method

README.md

@@ -121,6 +121,9 @@ parentPort.onMessage('ack', payload => {
     path: ' /',
   });
 });
+
+// 4. If you want to remove some listeners
+parentPort.offListener('ack');
 ```
 
 3. Child process implementation:
@@ -154,6 +157,13 @@ childPort.onMessage('syn', payload => {
 childPort.onMessage('body', payload => {
   console.log('[child] [body]', JSON.stringify(payload));
 });
+
+// 4. If you want to remove some listeners by `offMessage`
+const handleSyn = (payload) => {
+  console.log('[child] [syn]');
+};
+childPort.onMessage('syn', handleSyn);
+childPort.offListener('syn', handleSyn);
 ```
 
 ## 📖 Basic Concepts

src/index.ts

@@ -116,6 +116,10 @@ interface Port<T extends MessageDefinition, D extends Direction<T>> {
     t: U,
     handler: Callback<[Payload<T, ReverseDirection<T, D>, U>]>,
   ): void;
+  offListener<U extends keyof T[ReverseDirection<T, D>]>(
+    t: U,
+    handler?: Callback<[Payload<T, ReverseDirection<T, D>, U>]>,
+  ): void;
 }
 
 export type EnsureString<T> = T extends string ? T : never;
@@ -258,6 +262,20 @@ export class Unport<
     this.handlers[t].push(handler);
   };
 
+  public offListener: Port<T, InferDirectionByPort<T, U>>['offListener'] = (t, handler) => {
+    if (!this.handlers[t]) {
+      return;
+    }
+    if (handler) {
+      this.handlers[t] = this.handlers[t].filter(h => h !== handler);
+      if (this.handlers[t].length === 0) {
+        delete this.handlers[t];
+      }
+    } else {
+      delete this.handlers[t];
+    }
+  };
+
   public destroy() {
     this.handlers = {};
     this.channel?.destroy && this.channel.destroy();