-
chunked(int chunkSize)
→ Stream<List<T>>
-
Available on Stream<T>,
provided by the StreamExt extension
-
complete()
→ Future<void>
-
Available on Stream<T>,
provided by the StreamExt extension
-
mapAsyncLimited<E>(FutureOr<E> convert(T event), {int maxPending = 1})
→ Stream<E>
-
Available on Stream<T>,
provided by the StreamExt extension
