Struct PeekedRecv 

struct PeekedRecv {
    inner: RecvStream,
    prefix: Bytes,
}

A receive stream with bytes already taken off it.

Nothing says what a unidirectional stream is for until its first varint has been read, and reading it consumes it. The classifier hands those bytes back here, and the pipe that takes the stream reads them first and the transport afterwards, so a stream that was classified is indistinguishable from one that was not.

On drafts whose streams are never classified the prefix is empty and this is a RecvStream with one extra branch on the read path.

Fields

inner: RecvStream

prefix: Bytes

Bytes taken off inner before it was handed over, not yet handed to a reader.

Implementations

impl PeekedRecv

fn new(inner: RecvStream) -> Self

A stream nothing has been read from.

fn with_prefix(inner: RecvStream, prefix: Bytes) -> Self

A stream prefix was read from, to be replayed before the rest.

fn stream_id(&self) -> u64

See RecvStream::stream_id.

async fn read( &mut self, buf: &mut [u8], ) -> Result<Option<usize>, TransportError>

See RecvStream::read, with the replayed prefix ahead of it.

Cancel-safe for the same reason RecvStream::read is, and the prefix branch adds nothing to worry about: it awaits nothing, so it either runs to completion on its first poll or is never entered at all.

async fn received_reset(&mut self) -> Result<Option<u64>, TransportError>

See RecvStream::received_reset.

Not affected by the prefix: a peer’s RESET_STREAM is about the stream, and bytes already taken off it were taken before it was sent.

fn stop(&mut self, code: u64) -> Result<(), TransportError>

See RecvStream::stop. The unread prefix goes with everything else that was in flight.