Struct StreamReceiver 

pub(crate) struct StreamReceiver {
    pub(super) data: Receiver<Held>,
    pub(super) reset: CancellationToken,
    pub(super) remote_closed: Arc<AtomicBool>,
    pub(super) _live: Arc<Live>,
}

The data the client sends on a stream.

Fields

data: Receiver<Held>

reset: CancellationToken

remote_closed: Arc<AtomicBool>

_live: Arc<Live>

Implementations

impl StreamReceiver

pub(crate) async fn recv(&mut self) -> Option<Bytes>

The next data, None once the client closed its side, the stream got reset or the connection ended.

pub(crate) async fn recv_held(&mut self) -> Option<Held>

The next data like Self::recv, which still counts against the budget of the connection while it is held.

pub(crate) fn is_reset(&self) -> bool

Whether the stream got reset or the connection ended.

pub(crate) fn is_closed_by_client(&self) -> bool

Whether the client closed its side, also if the stream got reset or the connection ended afterwards.

Trait Implementations

impl Input for StreamReceiver

async fn recv(&mut self) -> Option<Held>

The next data, None once the client is done.