pub fn batch<T>(t: T, nondet: NonDet) -> Batch<T>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.