Struct bao_tree::io::fsm::ResponseDecoderReading

pub struct ResponseDecoderReading<R>(/* private fields */);

Response decoder state machine, after reading the size

Implementations

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

pub fn new(hash: Hash, ranges: ChunkRanges, 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

pub fn tree(&self) -> BaoTree

The tree geometry

pub fn hash(&self) -> &Hash

Hash of the blob we are currently getting

Trait Implementations

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

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

Formats the value using the given formatter.