foster/denoland-deno
1
0
Fork 0
mirror of https://github.com/denoland/deno.git synced 2025-01-07 22:58:24 -05:00
Code Issues Packages 1 Wiki Activity

support once listener

Browse source
This commit is contained in:
Yoshiya Hinosawa 2024-10-25 01:12:59 +09:00
parent ee4c391886
commit 8ece841314
No known key found for this signature in database
GPG key ID: 9017DB4559488785
1 changed files with 5 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
ext/node/polyfills/net.ts
View file

@ -360,15 +360,17 @@ function _afterConnect(
socket._unrefTimer(); socket._unrefTimer();
const connectListeners = socket.listenerCount("connect");
const readyListeners = socket.listenerCount("ready");
const dataListeners = socket.listenerCount("data");
socket.emit("connect"); socket.emit("connect");
socket.emit("ready"); socket.emit("ready");
// Note: This is Deno specific logic // Note: This is Deno specific logic
// If there's no listener for the connect, ready, data event, // If there's no listener for the connect, ready, data event,
// we delay the first read. This is necessary for http.request to work properly. // we delay the first read. This is necessary for http.request to work properly.
const connectListeners = socket.listenerCount("connect"); // See https://github.com/denoland/deno/pull/25470#issuecomment-2435077722
const readyListeners = socket.listenerCount("ready");
const dataListeners = socket.listenerCount("data");
if (connectListeners === 0 && readyListeners === 0 && dataListeners === 0) { if (connectListeners === 0 && readyListeners === 0 && dataListeners === 0) {
return; return;
} }