Function pipe

pub fn pipe<S: Stream, const N: usize>(
    source: S,
    sink: Sender<S::Item, N>,
) -> Pipe<S, N> 

Pipe a stream into a batching sender

This will poll the stream for as long as items are forthcoming and the current bucket still has room. When the latter condition is hit, the task is rescheduled to make room for other tasks to run on the current executor.