diff options
Diffstat (limited to 'test/bun.js/socket/echo.js')
-rw-r--r-- | test/bun.js/socket/echo.js | 76 |
1 files changed, 0 insertions, 76 deletions
diff --git a/test/bun.js/socket/echo.js b/test/bun.js/socket/echo.js deleted file mode 100644 index f02637739..000000000 --- a/test/bun.js/socket/echo.js +++ /dev/null @@ -1,76 +0,0 @@ -function createOptions(type, message, closeOnDone) { - let buffers = []; - let report = function () { - report = function () {}; - const data = new Uint8Array( - buffers.reduce(function (sum, buffer) { - return sum + buffer.length; - }, 0), - ); - buffers.reduce(function (offset, buffer) { - data.set(buffer, offset); - return offset + buffer.length; - }, 0); - console.log(type, "GOT", new TextDecoder().decode(data)); - }; - - let done = closeOnDone - ? function (socket, sent) { - socket.data[sent ? "sent" : "received"] = true; - if (socket.data.sent && socket.data.received) { - done = function () {}; - closeOnDone(socket); - } - } - : function () {}; - - function drain(socket) { - const message = socket.data.message; - const written = socket.write(message); - if (written < message.length) { - socket.data.message = message.slice(written); - } else { - done(socket, true); - } - } - - return { - hostname: "localhost", - port: 12345, - socket: { - close() { - report(); - console.log(type, "CLOSED"); - }, - data(socket, buffer) { - buffers.push(buffer); - done(socket); - }, - drain: drain, - // end() { - // report(); - // console.log(type, "ENDED"); - // }, - error(socket, err) { - console.log(type, "ERRED", err); - }, - open(socket) { - console.log(type, "OPENED"); - drain(socket); - }, - }, - data: { - sent: false, - received: false, - message: message, - }, - }; -} - -const server = Bun.listen( - createOptions("[Server]", "response", socket => { - server.stop(); - socket.end(); - }), -); -Bun.connect(createOptions("[Client]", "request")); |