Struct bao_tree::io::fsm::ResponseDecoderReading

pub struct ResponseDecoderReading<R>(_);

Response decoder state machine, after reading the size

Implementations

impl<R: AsyncRead + Unpin> ResponseDecoderReading<R>

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

Create a new response decoder state machine, when you have already read the size.

The size as well as the chunk size is given in the tree parameter.

pub async fn next(self) -> ResponseDecoderReadingNext<R>

Proceed to the next state by reading the next chunk from the stream.

pub fn finish(self) -> R

Immediately return the underlying reader

Trait Implementations

impl<R: Debug> Debug for ResponseDecoderReading<R>

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

Formats the value using the given formatter.