Class swarmauri_core.transports.i_multiplex.IMultiplexTransport

swarmauri_core.transports.i_multiplex.IMultiplexTransport

Bases: ABC

Interface for transports that expose multiplexed channels.

open_channel abstractmethod async

open_channel()

Open a logical channel on the transport.

Source code in swarmauri_core/transports/i_multiplex.py

@abstractmethod
async def open_channel(self) -> ChannelHandle:
    """Open a logical channel on the transport."""

close_channel abstractmethod async

close_channel(handle)

Close a previously opened channel.

Source code in swarmauri_core/transports/i_multiplex.py

@abstractmethod
async def close_channel(self, handle: ChannelHandle) -> None:
    """Close a previously opened channel."""

send_on abstractmethod async

send_on(handle, data, *, timeout=None)

Send data on a specific channel.

Source code in swarmauri_core/transports/i_multiplex.py

@abstractmethod
async def send_on(
    self, handle: ChannelHandle, data: bytes, *, timeout: Optional[float] = None
) -> None:
    """Send data on a specific channel."""

recv_on abstractmethod async

recv_on(handle, *, timeout=None)

Receive data from a specific channel.

Source code in swarmauri_core/transports/i_multiplex.py

@abstractmethod
async def recv_on(
    self, handle: ChannelHandle, *, timeout: Optional[float] = None
) -> bytes:
    """Receive data from a specific channel."""