feat: notify listeners for each outgoing packet

Related: - socketio/socket.io#4145 - #78
socketio · Mar 29, 2022 · 38ee887 · 38ee887
1 parent a7f1c90
commit 38ee887
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/lib/index.ts b/lib/index.ts
@@ -146,6 +146,10 @@ export class Adapter extends EventEmitter {
     const encodedPackets = this.encoder.encode(packet);
 
     this.apply(opts, socket => {
+      if (typeof socket.notifyOutgoingListeners === "function") {
+        socket.notifyOutgoingListeners(packet);
+      }
+
       socket.client.writeToEngine(encodedPackets, packetOpts);
     });
   }
@@ -192,6 +196,10 @@ export class Adapter extends EventEmitter {
       // call the ack callback for each client response
       socket.acks.set(packet.id, ack);
 
+      if (typeof socket.notifyOutgoingListeners === "function") {
+        socket.notifyOutgoingListeners(packet);
+      }
+
       socket.client.writeToEngine(encodedPackets, packetOpts);
     });