We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent c9137f5 commit 5a31a01Copy full SHA for 5a31a01
reflex/state.py
@@ -3641,6 +3641,10 @@ async def close(self):
3641
redis = await self.get_redis()
3642
await redis.close()
3643
3644
+ for pubsub in self._pubsub_clients.values():
3645
+ await pubsub.close()
3646
+ self._pubsub_clients = {}
3647
+
3648
3649
def get_state_manager() -> StateManager:
3650
"""Get the state manager for the app that is currently running.
0 commit comments