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<(Self, Result<DecodeResponseItem, DecodeError>), R>

pub fn finish(self) -> R

Trait Implementations

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

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

Formats the value using the given formatter.