reconnecting-socket.ts

const port = process.argv[2];
const host = process.argv[3];

const delay = 1000;
const socket = new net.Socket();
socket.on('close', () => {
  setTimeout(() => {
    socket.connect(port, host);
  }, delay);
});
socket.connect(port, 'localhost');
const socketWithDisconnectionBuffer = bufferChunksUntilConnected(socket);

// and make use of socketWithDisconnectionBuffer!

function bufferChunksUntilConnected(socket: net.Socket) {
  const passthrough = new stream.PassThrough();
  socket
    .on('connect', () => {
      passthrough.pipe(socket);
    })
    .on('close', () => {
      passthrough.unpipe(socket);
    });
  return passthrough;
}