ValueStreamExtensions<T> extension

on

Methods

combined<R, O>(ValueStream<O> other, R combiner(T? self, O? other)) → ValueStream<R>: Available on ValueStream<T>, provided by the ValueStreamExtensions extension
Combines another stream.
combinedUnresolved<R, O>(ValueStream<O> other, Resolvable<R?> combiner(FutureOr<T?> self, FutureOr<O?> other)) → ValueStream<R?>: Available on ValueStream<T>, provided by the ValueStreamExtensions extension
Combines another stream, passing unresolved Futures
debounced([Duration? duration]) → ValueStream<T>: Available on ValueStream<T>, provided by the ValueStreamExtensions extension
flatten([T? initialValue, bool filterNotNull = true]) → Stream<T?>: Available on ValueStream<T>, provided by the ValueStreamExtensions extension
listen(void onData(T item)) → StreamSubscription: Available on ValueStream<T>, provided by the ValueStreamExtensions extension
peek(void peek(T item)) → ValueStream<T>: Available on ValueStream<T>, provided by the ValueStreamExtensions extension
toSyncStream([void onChange(T value)?, String? name]) → SyncStream<T>: Available on ValueStream<T>, provided by the ValueStreamExtensions extension
where(Predicate<T?> predicate) → ValueStream<T>: Available on ValueStream<T>, provided by the ValueStreamExtensions extension
Filters the entire stream, including the current element
whereNotNull() → ValueStream<T>: Available on ValueStream<T>, provided by the ValueStreamExtensions extension