Method write_message_async

gunicorn/dirty/protocol.py:468–485

Write a message to async stream. Accepts dict format for backwards compatibility. Args: writer: asyncio StreamWriter message: Message dict with 'type', 'id', and payload fields Raises: DirtyProtocolError: If encoding fails

(writer: asyncio.StreamWriter,
                                  message: dict)

    @staticmethod
    async def write_message_async(writer: asyncio.StreamWriter,
                                  message: dict) -> None:
        """
        Write a message to async stream.

        Accepts dict format for backwards compatibility.

        Args:
            writer: asyncio StreamWriter
            message: Message dict with 'type', 'id', and payload fields

        Raises:
            DirtyProtocolError: If encoding fails
            ConnectionError: If write fails
        """
        data = BinaryProtocol._encode_from_dict(message)
        writer.write(data)
        await writer.drain()

    # -------------------------------------------------------------------------
    # Sync API (for HTTP workers that may not be async)