Struct RawStreamReceiver 

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

Sole consuming raw receiver. Dropping it disables sends and starts draining.

Implementations

impl<P> RawStreamReceiver<P>

where P: Protocol,

pub fn id(&self) -> u32

Correlation ID whose frames this receiver alone consumes.

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

Receive the next frame. EOF before terminal is an error exactly once.

pub fn close(&mut self)

Stop local consumption and disable sends without canceling remote work.

Trait Implementations

impl<P> Drop for RawStreamReceiver<P>

where P: Protocol,

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.