StreamExt<T> extension

on

• Stream<T>

Methods

chunked(int chunkSize) → Stream<List<T>>

complete() → Future<void>

mapAsyncLimited<E>(FutureOr<E> convert(T event), {int maxPending = 1}) → Stream<E>