aboutsummaryrefslogtreecommitdiff
path: root/src/js/node/net.js
diff options
context:
space:
mode:
Diffstat (limited to 'src/js/node/net.js')
-rw-r--r--src/js/node/net.js8
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;