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: ChunkRanges, 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), StartDecodeError>

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.

pub fn hash(&self) -> &Hash

Hash of the blob we are currently getting

pub fn ranges(&self) -> &ChunkRanges

The ranges we requested

Trait Implementations

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

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

Formats the value using the given formatter.