Struct bao_tree::io::fsm::ResponseDecoderStart

pub struct ResponseDecoderStart<R> { /* private fields */ }

Response decoder state machine, at the start of a stream

Implementations

impl<'a, R: AsyncRead + Unpin> ResponseDecoderStart<R>

pub fn new( hash: Hash, ranges: RangeSet2<ChunkNum>, block_size: BlockSize, encoded: R ) -> Self

Create a new response decoder state machine, at the start of a stream where you don’t yet know the size.

pub fn finish(self) -> R

Immediately finish decoding the stream, returning the underlying reader

pub async fn next(self) -> Result<(ResponseDecoderReading<R>, u64), Error>

Read the size and go into the next state

The only thing that can go wrong here is an io error when reading the size.

Trait Implementations

impl<R: Debug> Debug for ResponseDecoderStart<R>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.