`unienv_interface.remote.transport`¶

Ordered, reliable binary message transports. WebSocket is an optional extra.

TransportClosed ¶

Bases: ConnectionError

Bases: Protocol

One reader and one writer may run concurrently; close unblocks both.

Implementations preserve complete message boundaries and order. They must bound buffering and raise ConnectionError/OSError on transport failure.

send(payload: bytes) -> None

recv() -> bytes

close() -> None

MemoryTransport(incoming: _Channel, outgoing: _Channel)

Bounded, byte-copying transport for tests and embedded deployments.

pair(capacity: int = 16) -> Tuple[MemoryTransport, MemoryTransport]

send(payload: bytes) -> None

recv() -> bytes

close() -> None

WebSocketTransport(connection: Connection)

connection = connection

connect(uri: str, *, max_message_size: int = DEFAULT_MAX_MESSAGE_SIZE, **kwargs: object) -> WebSocketTransport

send(payload: bytes) -> None

recv() -> bytes

close() -> None