Class swarmauri_core.transports.i_broadcast.IBroadcastTransport

swarmauri_core.transports.i_broadcast.IBroadcastTransport

Bases: ABC

Interface for transports supporting broadcast messages.

broadcast abstractmethod async

broadcast(data, *, timeout=None)

Broadcast data to all peers reachable by the transport.

Source code in swarmauri_core/transports/i_broadcast.py

@abstractmethod
async def broadcast(self, data: bytes, *, timeout: Optional[float] = None) -> None:
    """Broadcast data to all peers reachable by the transport."""