Fix race

replit · May 3, 2024 · 63b5f4a · 63b5f4a
1 parent ce47474
commit 63b5f4a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/replit_river/session.py b/replit_river/session.py
@@ -211,7 +211,7 @@ async def replace_with_new_websocket(
                 self._reset_session_close_countdown()
                 await old_wrapper.close()
             self._ws_wrapper = WebsocketWrapper(new_ws)
-            await self._send_buffered_messages(new_ws)
+        await self._send_buffered_messages(new_ws)
         # Server will call serve itself.
         if not self._is_server:
             await self.start_serve_responses()