Struct SliceStreamProducer 

pub struct SliceStreamProducer<P>
where
    P: BulkProducer<Item = u8>,
{ /* private fields */ }

A BulkProducer<Item=u8> produced by a DropDecoder, which produces the verifiable slice stream for one contiguous slice of the payload of one AuthorisedEntry decoded from the Willow Drop Format.

Warning

Any SliceStreamProducer produced by a DropDecoder must be completely consumed, emitting its Final value in order for further calls to DropDecoder::produce to make progress.

Trait Implementations

impl<P> BulkProducer for SliceStreamProducer<P>

where P: BulkProducer<Item = u8>,

async fn expose_items_gracefully<F, R>( &mut self, f: F, ) -> Result<Either<R, (F, Self::Final)>, (F, Self::Error)>

where F: AsyncFnOnce(&[Self::Item]) -> (usize, R),

Exposes a non-empty number of items to a given async function, the function then reports to the producer how many items should now be considered produced.

impl<P> Producer for SliceStreamProducer<P>

where P: BulkProducer<Item = u8>,

type Item = <P as Producer>::Item

The sequence produced by this producer starts with arbitrarily many values of this type.

type Final = ()

The sequence produced by this producer ends with up to one value of this type.

type Error = DecodeError<(), <P as Producer>::Error, Blame>

The type of errors the producer can emit instead of doing its job.

async fn produce( &mut self, ) -> Result<Either<Self::Item, Self::Final>, Self::Error>

Attempts to produce the next item, which is either a regular repeated item or the final value. The method may fail, returning an Err instead.

async fn slurp(&mut self) -> Result<(), Self::Error>

Attempts to perform any effectful actions that might make future calls to produce and bulk_produce more efficient.