Enter to sendĀ·Shift+Enter new line
handle_message_chunk( self, payload: Any, ) -> AsyncIterator[Any]
Accumulate per-message output; publish only the queue head.
