Struct Stream 

pub struct Stream<P: Protocol> { /* private fields */ }

Decoded message stream over the same opaque router and lease.

Implementations

impl<P: Protocol> Stream<P>

pub fn id(&self) -> u32

Correlation ID of the owned stream.

pub async fn send<M: IntoOutboundMessage<P>>( &self, message: M, ) -> ClientResult<()>

Send a native or already-encoded payload using the selected codec.

pub async fn recv(&mut self) -> ClientResult<Option<Message>>

Receive an inspectable message, including unknown names and peer errors.

pub fn close(&mut self)

Abandon consumption; no domain-specific cancellation or EOF is sent.

pub fn into_parts(self) -> (StreamSender<P>, StreamReceiver<P>)

Split into owned handles while preserving one receiver and the ID lease.