fix test

socketio · Jun 21, 2024 · 5a0c6f2 · 5a0c6f2
1 parent 502b728
commit 5a0c6f2
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/lib/transports-uws/polling.ts b/lib/transports-uws/polling.ts
@@ -97,7 +97,7 @@ export class Polling extends Transport {
  res.onAborted(onClose);
 
  this.writable = true;
- this.emit("drain");
+ this.emit("ready");
 
  // if we're still writable but had a pending close, trigger an empty send
  if (this.writable && this.shouldClose) {
@@ -291,6 +291,7 @@ export class Polling extends Transport {
  debug('writing "%s"', data);
  this.doWrite(data, options, () => {
  this.req.cleanup();
+ this.emit("drain");
  });
  }
 

diff --git a/lib/transports-uws/websocket.ts b/lib/transports-uws/websocket.ts
@@ -60,8 +60,9 @@ export class WebSocket extends Transport {
  this.socket.send(data, isBinary, compress);
 
  if (isLast) {
- this.writable = true;
  this.emit("drain");
+ this.writable = true;
+ this.emit("ready");
  }
  };