Interface Nexus\Mcp\Core\Transport\TransportInterface

Begins consuming inbound envelopes from the peer. Returns immediately.

Enqueues an outbound JSON-RPC message to the peer. On write failure, close listeners fire before the exception is rethrown.

Closes the connection. The onClose() listener fires once after the underlying streams are closed. Subsequent calls are no-ops. Implementations MUST guarantee that onClose() listeners fire after a fatal error too, not only after explicit close(). Server::run() blocks on the close signal, so a transport that raises errors without eventually closing would hang the server loop.

Register an inbound-envelope listener.

Register an error listener.

Register a drain listener that fires before close().

Register a close listener.