StreamExtensions<T> extension

on

• Stream<T>

Methods

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

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

debounce(Duration duration) → Stream<T>

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

endWith(T value) → Stream<T>

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

firstWithTimeout(Duration duration) → Future<T>

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

log({String? tag}) → Stream<T>

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

mapNotNull<R>(R? transform(T)) → Stream<R>

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

mergeWith(Stream<T> other) → Stream<T>

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

onErrorReturn(T fallback) → Stream<T>

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

retryWhen(bool shouldRetry(Object other), {int maxRetries = 3, Duration delay = const Duration(seconds: 1)}) → Stream<T>

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

sliding(int windowSize) → Stream<List<T>>

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

startWith(T value) → Stream<T>

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

throttle(Duration duration) → Stream<T>

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

toListAsync() → Future<List<T>>

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

whereNotNull() → Stream<T>

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

whereType<T>() → Stream<T>

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