We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 81f587e commit 4cd4cb3Copy full SHA for 4cd4cb3
1 file changed
packages/engine.io/lib/server.ts
@@ -548,6 +548,7 @@ export abstract class BaseServer extends EventEmitter {
548
const result = await streamReader.read();
549
550
if (result.done) {
551
+ clearTimeout(timeout);
552
debug("session is closed");
553
return;
554
}
@@ -561,13 +562,13 @@ export abstract class BaseServer extends EventEmitter {
561
562
563
// reading the first packet of the stream
564
const { value, done } = await reader.read();
565
566
+
567
if (done) {
568
debug("stream is closed");
569
570
571
- clearTimeout(timeout);
-
572
if (value.type !== "open") {
573
debug("invalid WebTransport handshake");
574
return session.close();
0 commit comments