Struct RawStream 

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

Opaque frame stream whose lifetime retains its connection and ID lease.

Implementations

impl<P> RawStream<P>

where P: Protocol,

pub fn id(&self) -> u32

Current stream’s correlation ID.

pub async fn send(&self, flags: u8, body: &[u8]) -> Result<(), ClientError>

Send a follow-up opaque frame; local close never sends a protocol signal.

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

Receive each frame, terminal included, then clean exhaustion or an error.

pub fn close(&mut self)

Abandon local consumption and retain bounded drain state until terminal.

pub fn into_parts(self) -> (RawStreamSender<P>, RawStreamReceiver<P>)

Move ownership into a cloneable sender and one consuming receiver.