diff --git a/packages/backend/src/server/api/StreamingApiServerService.ts b/packages/backend/src/server/api/StreamingApiServerService.ts index b6b930a434..783f6af34e 100644 --- a/packages/backend/src/server/api/StreamingApiServerService.ts +++ b/packages/backend/src/server/api/StreamingApiServerService.ts @@ -220,6 +220,8 @@ export class StreamingApiServerService implements OnApplicationShutdown { if (connectionsForClient.size < 1) { this.#connectionsByClient.delete(limitActor); } + + stream.dispose(); }); ws.once('error', (e) => {