diff --git a/.changeset/pink-rings-listen.md b/.changeset/pink-rings-listen.md new file mode 100644 index 0000000..29908ab --- /dev/null +++ b/.changeset/pink-rings-listen.md @@ -0,0 +1,5 @@ +--- +"nxjs-runtime": patch +--- + +Close TCP socket when writable stream is closed diff --git a/packages/runtime/src/tcp.ts b/packages/runtime/src/tcp.ts index d4f9d0b..77ec9c6 100644 --- a/packages/runtime/src/tcp.ts +++ b/packages/runtime/src/tcp.ts @@ -128,6 +128,9 @@ export class Socket { } await (i.tls ? tlsWrite(i.tls, chunk) : write(i.fd, chunk)); }, + close() { + socket.close(); + }, }); connect(address)