fuel_core_services::yield_stream

Trait StreamYieldExt

source
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§

source

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

Yields each batch_size items allowing other tasks to work.

Implementors§

source§

impl<St> StreamYieldExt for St
where St: Stream,