pub trait StreamYieldExt: Stream {
// Provided method
fn yield_each(self, batch_size: usize) -> YieldStream<Self>
where Self: Sized { ... }
}
Expand description
Extension trait for Stream
.
Provided Methods§
sourcefn yield_each(self, batch_size: usize) -> YieldStream<Self>where
Self: Sized,
fn yield_each(self, batch_size: usize) -> YieldStream<Self>where
Self: Sized,
Yields each batch_size
items allowing other tasks to work.