Struct Cleaver 

pub struct Cleaver<B, E, St>
where
    B: Splittable + Unpin,
    St: Stream<Item = Result<B, E>>,
{ /* private fields */ }

A Stream adapter that splits buffers from a source to a given, maximum length.

This may be useful to limit the amount of time spent processing each Item of a Splittable stream. This is enabled via the cleaver feature.

Implementations

impl<B, E, St> Cleaver<B, E, St>

where B: Splittable + Unpin, St: Stream<Item = Result<B, E>>,

pub fn new(source: St, max: usize) -> Self

Construct with source and maximum size to split on.

The size to split on must be at least 1.

Trait Implementations

impl<B, E, St> Debug for Cleaver<B, E, St>

where B: Splittable + Unpin, St: Stream<Item = Result<B, E>> + Debug,

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

Formats the value using the given formatter.

impl<B, E, St> Stream for Cleaver<B, E, St>

where B: Splittable + Unpin, St: Stream<Item = Result<B, E>>,

type Item = Result<B, E>

Values yielded by the stream.

fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Self::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.