Trait StreamYieldExt 

pub trait StreamYieldExt: Stream {
    // Provided method
    fn yield_each(self, batch_size: usize) -> YieldStream<Self>
       where Self: Sized { ... }
}

Extension trait for Stream.

Provided Methods

fn yield_each(self, batch_size: usize) -> YieldStream<Self>

where Self: Sized,

Yields each batch_size items allowing other tasks to work.

Implementors

impl<St> StreamYieldExt for St

where St: Stream,