Struct Stream 

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

Decoded message stream over the same opaque router and lease.

Implementations

impl<P> Stream<P>

where P: Protocol,

pub fn id(&self) -> u32

Correlation ID of the owned stream.

pub async fn send<M>(&self, message: M) -> Result<(), ClientError>

where M: IntoOutboundMessage<P>,

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

pub async fn recv(&mut self) -> Result<Option<Message>, ClientError>

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.