Function send_outgoing_messages

src/websockets/cli.py:89–101

(
    websocket: ClientConnection,
    messages: SimpleQueue[str],
)

async def send_outgoing_messages(
    websocket: ClientConnection,
    messages: SimpleQueue[str],
) -> None:
    while True:
        try:
            message = await messages.get()
        except EOFError:
            break
        try:
            await websocket.send(message)
        except ConnectionClosed:  # pragma: no cover
            break


async def interactive_client(uri: str) -> None: