We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 7708834 commit d3dea98Copy full SHA for d3dea98
packages/api/src/flux0_api/sessions.py
@@ -314,6 +314,7 @@ async def subscriber_final(emitted_event: EmittedEvent) -> None:
314
# Unsubscribe when client disconnects
315
print("unsubscribed from correlation_id", correlation_id)
316
event_emitter.unsubscribe_processed(correlation_id, subscriber)
317
+ event_emitter.unsubscribe_final(correlation_id, subscriber_final)
318
# Explicitly send a termination event before closing
319
# yield "event: close\ndata: {}\n\n"
320
0 commit comments