Interface Nexus\Mcp\Core\Transport\TransportInterface

Begins consuming inbound envelopes from the peer, returning immediately.

Enqueues an outbound JSON-RPC message to the peer, close listeners firing before a write failure is rethrown.

Closes the connection once, firing onClose() after the underlying streams close, which an implementation MUST also do after a fatal error since Server::run() blocks on that signal. A call from another fiber while a close is in progress MUST block until that close settles, while one re-entering from the closing fiber returns immediately.

A transport multiplexing several peers MUST namespace or rewrite inbound request ids before emitting them, since the protocol layer correlates and cancels by id alone.

Register a drain listener that fires before close().