aboutsummaryrefslogtreecommitdiff
path: root/src/bun.js/net.exports.js
diff options
context:
space:
mode:
Diffstat (limited to 'src/bun.js/net.exports.js')
-rw-r--r--src/bun.js/net.exports.js11
1 files changed, 6 insertions, 5 deletions
diff --git a/src/bun.js/net.exports.js b/src/bun.js/net.exports.js
index 928189dd3..b4229a271 100644
--- a/src/bun.js/net.exports.js
+++ b/src/bun.js/net.exports.js
@@ -86,14 +86,14 @@ export const Socket = (function (InternalSocket) {
self.emit("error", error);
},
- data({ data: self }, { length, buffer }) {
- self.bytesRead += length;
+ data({ data: self }, buffer) {
+ self.bytesRead += buffer.length;
const queue = self.#readQueue;
- const ret = new Buffer(buffer);
+
if (queue.isEmpty()) {
- if (self.push(ret)) return;
+ if (self.push(buffer)) return;
}
- queue.push(ret);
+ queue.push(buffer);
},
drain: Socket.#Drain,
end: Socket.#Close,
@@ -120,6 +120,7 @@ export const Socket = (function (InternalSocket) {
const self = socket.data;
self.emit("timeout");
},
+ binaryType: "buffer",
};
static #Close(socket) {