Piping two TCP connections to each other

const listener = Deno.listen({
  hostname: "127.0.0.1",
  port: 8445,
  transport: "tcp",
});
for await (const inConn of listener) {
  const buf = new Uint8Array(4096);

  await inConn.read(buf);
  // TODO Routing logic
  console.log("Connecting to local server (OUT)...");
  const outConn = await Deno.connect({
    hostname: "127.0.0.1",
    port: 8443,
    transport: "tcp",
  });
  console.log("Flushing buffer to OUT");
  await outConn.write(buf);

  console.log("Send all other data from IN to OUT");
  inConn.readable.pipeTo(outConn.writable);

  console.log("Send all other data from OUT to IN");
  outConn.readable.pipeTo(inConn.writable);

  console.log("Finished establishing connetion");
}

Connecting to local server (OUT)...
Flushing buffer to OUT
Send all other data from IN to OUT
Send all other data from OUT to IN
Finished establishing connetion
error: Uncaught (in promise) Interrupted: operation canceled
    at async Object.pull (ext:deno_web/06_streams.js:991:27)