swarmauri_transport_sseoutbound 0.11.0.dev1

Server-Sent Events broadcaster transport for Swarmauri agents.

Swarmauri Transport ? Server-Sent Events

swarmauri-transport-sseoutbound hosts a lightweight SSE endpoint for broadcasting real-time updates to browsers or other streaming clients.

Installation

Using uv

uv pip install swarmauri-transport-sseoutbound --index-url https://pypi.org/simple

Using pip

pip install swarmauri-transport-sseoutbound

Usage

import asyncio
from swarmauri_transport_sseoutbound import SSEOutboundTransport

async def main() -> None:
    transport = SSEOutboundTransport()
    async with transport.server(host="0.0.0.0", port=8082):
        await transport.broadcast(b"hello, world!")

asyncio.run(main())

Attach your own event loop or scheduler to push updates whenever your agents produce new data.