diff options
author | 2023-01-07 23:58:25 -0800 | |
---|---|---|
committer | 2023-01-07 23:58:25 -0800 | |
commit | 4eb3067ef54ef5e8414bed681cfa29c8989e955d (patch) | |
tree | 0501d3232e3ab555e53c38fc9783e14aec8a1dc5 /test/bun.js | |
parent | 3c8701362bee0c1cc8ececd0f1a87c1665376a24 (diff) | |
download | bun-4eb3067ef54ef5e8414bed681cfa29c8989e955d.tar.gz bun-4eb3067ef54ef5e8414bed681cfa29c8989e955d.tar.zst bun-4eb3067ef54ef5e8414bed681cfa29c8989e955d.zip |
Workaround macOS issue
Diffstat (limited to 'test/bun.js')
-rw-r--r-- | test/bun.js/socket/echo.js | 42 | ||||
-rw-r--r-- | test/bun.js/socket/socket.test.ts | 2 |
2 files changed, 25 insertions, 19 deletions
diff --git a/test/bun.js/socket/echo.js b/test/bun.js/socket/echo.js index e864f1b2b..40acd631c 100644 --- a/test/bun.js/socket/echo.js +++ b/test/bun.js/socket/echo.js @@ -1,24 +1,28 @@ 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) { + 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() {}; + 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; @@ -63,8 +67,10 @@ function createOptions(type, message, closeOnDone) { }; } -const server = Bun.listen(createOptions("[Server]", "response", socket => { - server.stop(); - socket.end(); -})); +const server = Bun.listen( + createOptions("[Server]", "response", (socket) => { + server.stop(); + socket.end(); + }), +); Bun.connect(createOptions("[Client]", "request")); diff --git a/test/bun.js/socket/socket.test.ts b/test/bun.js/socket/socket.test.ts index 28c945f64..f9218493f 100644 --- a/test/bun.js/socket/socket.test.ts +++ b/test/bun.js/socket/socket.test.ts @@ -37,7 +37,7 @@ it("should reject on connection error, calling both connectError() and rejecting var data = {}; connect({ data, - hostname: "127.0.0.1", + hostname: "localhost", port: 55555, socket: { connectError(socket, error) { |