pub fn batch<T, H>(t: T, nondet: NonDet<H>) -> Batch<T, H>Expand description
Wraps a stream-like live collection (such as a Stream,
KeyedStream, or a
KeyedSingleton with bounded values) to be
sliced into non-deterministic batches of asynchronously arriving elements.