diff options
Diffstat (limited to 'src/js/node/net.js')
-rw-r--r-- | src/js/node/net.js | 8 |
1 files changed, 3 insertions, 5 deletions
diff --git a/src/js/node/net.js b/src/js/node/net.js index 0513f44d3..f0873ae22 100644 --- a/src/js/node/net.js +++ b/src/js/node/net.js @@ -89,10 +89,6 @@ const Socket = (function (InternalSocket) { class Socket extends Duplex { static #Handlers = { close: Socket.#Close, - connectError(socket, error) { - const self = socket.data; - self.emit("error", error); - }, data({ data: self }, buffer) { self.bytesRead += buffer.length; const queue = self.#readQueue; @@ -448,8 +444,8 @@ const Socket = (function (InternalSocket) { if (connectListener) this.on("secureConnect", connectListener); } else if (connectListener) this.on("connect", connectListener); - // start using existing connection + // start using existing connection if (connection) { const socket = connection[bunSocketInternal]; @@ -508,6 +504,7 @@ const Socket = (function (InternalSocket) { tls, }).catch(error => { this.emit("error", error); + this.emit("close"); }); } else { // default start @@ -519,6 +516,7 @@ const Socket = (function (InternalSocket) { tls, }).catch(error => { this.emit("error", error); + this.emit("close"); }); } return this; |