Struct ResponseDecoder

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

Response decoder

Implementations

impl<R: AsyncStreamReader> ResponseDecoder<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) -> ResponseDecoderNext<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 ResponseDecoder<R>

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

Formats the value using the given formatter.