StreamExtensions<T> extension

Batch Processing & Mapping for Streams

on

• Stream<T>

Methods

asyncMap<R>(Future<R> mapper(T)) → Stream<R>

Available on Stream<T>, provided by the StreamExtensions extension

Maps values asynchronously

batch(int batchSize) → Stream<List<T>>

Available on Stream<T>, provided by the StreamExtensions extension

Batches stream values into lists of size batchSize

collect() → Future<List<T>>

Available on Stream<T>, provided by the StreamExtensions extension

Converts Stream into List

delayEach(Duration duration) → Stream<T>

Available on Stream<T>, provided by the StreamExtensions extension

Delays stream items