cli/bench/node_tcp_promise.js


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25

// Copyright 2018-2021 the Deno authors. All rights reserved. MIT license.
// Note: this is a keep-alive server.
const { Server } = require("net");
const port = process.argv[2] || "4544";
console.log("port", port);

const response = Buffer.from(
  "HTTP/1.1 200 OK\r\nContent-Length: 12\r\n\r\nHello World\n",
);

function write(socket, buffer) {
  const p = new Promise((resolve, _) => {
    socket.write(buffer, resolve);
  });
  return Promise.resolve(p);
}

Server(async (socket) => {
  socket.on("error", (_) => {
    socket.destroy();
  });
  for await (const _ of socket) {
    await write(socket, response);
  }
}).listen(port);