Dispose of the stream even if it gets closed early
This commit is contained in:
parent
5aceeb31e7
commit
155d2920b6
1 changed files with 2 additions and 0 deletions
|
|
@ -220,6 +220,8 @@ export class StreamingApiServerService implements OnApplicationShutdown {
|
||||||
if (connectionsForClient.size < 1) {
|
if (connectionsForClient.size < 1) {
|
||||||
this.#connectionsByClient.delete(limitActor);
|
this.#connectionsByClient.delete(limitActor);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
stream.dispose();
|
||||||
});
|
});
|
||||||
|
|
||||||
ws.once('error', (e) => {
|
ws.once('error', (e) => {
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue