Maybe this is where the slowdown is?

The while := should be a tight loop, but maybe too tight

Author: blast-hardcheese

src/replit_river/common_session.py

@@ -130,6 +130,7 @@ async def buffered_message_sender(
     logger.debug("Entering buffered_message_sender")
     while True:
         logger.debug("buffered_message_sender: LOOP")
+        sent = False
         while msg := get_next_pending():
             ws = get_ws()
             logger.debug("buffered_message_sender: Dequeued %r to send over %r", msg, ws)
@@ -140,6 +141,7 @@ async def buffered_message_sender(
                 await send_transport_message(msg, ws, websocket_closed_callback)
                 logger.debug("buffered_message_sender: committing!")
                 commit(msg)
+                sent = True
             except WebsocketClosedException as e:
                 logger.debug(
                     "Connection closed while sending message %r, waiting for "
@@ -157,7 +159,8 @@ async def buffered_message_sender(
             except Exception:
                 logger.exception("Error attempting to send buffered messages")
                 break
-        await asyncio.sleep(0.25)
+        if not sent:
+            await asyncio.sleep(0.25)
 
 
 async def add_msg_to_stream(