Struct RawStream 

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

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

Implementations

impl<P: Protocol> RawStream<P>

pub fn id(&self) -> u32

Current stream’s correlation ID.

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

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

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

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.