SIGN IN SIGN UP

fix: streaming response due to high number of redis pub/sub channels, better handling of connection issues (#6114)

* fix: unsubscribe redis pubsub when connection closes during prediction or after successful response

* update: add heartbeat to keep connection alive and start/stop heartbeat on server start/stop

* refactor: redis pub/sub methods, add unsubscribe, await subscribe

* fix: redundant unsubscribe

* fix: use map to store clients list

* fix: update how thinking event is handled in redis pub/sub and sse

* fix: review feedback
I
Ilango committed
1707688e62be94811ef977e701c071bc2d16d605
Parent: 14b6e41
Committed by GitHub <noreply@github.com> on 4/2/2026, 7:44:40 AM