StreamSignalMixin<T> mixin

Stream implementation for AsyncState

Superclass constraints

ReadonlySignal<T>

Implemented types

Stream<T>

Available extensions

Properties

autoDispose ↔ bool: Throws and error if read after dispose and can be disposed on last unsubscribe.
getter/setter pairinherited
bitLength → int: Available on ReadonlySignal<int>, provided by the IntSignalExtension extension
Returns the minimum number of bits required to store this integer.
no setter
codeUnits → List<int>: Available on ReadonlySignal<String>, provided by the StringSignalExtension extension
An unmodifiable list of the UTF-16 code units of this string.
no setter
debugLabel → String?: Debug label for Debug Mode
no setterinherited
disposed ↔ bool: Check if the effect is disposed
getter/setter pairinherited
entries → Iterable<MapEntry<K, V>>: Available on ReadonlySignal<Map<K, V>>, provided by the ReadonlyMapSignalExtension extension

no setter
first → E: Available on ReadonlySignal<Iterable<E>>, provided by the ReadonlyIterableSignalExtension extension

no setter
first → Future<T>: The first element of this stream.
no setteroverride
globalId → int: Global ID of the signal
no setterinherited
hashCode → int: The hash code for this object.
no setterinherited
index → int: Available on ReadonlySignal<Enum>, provided by the EnumSignalExtension extension
A numeric identifier for the enumerated value.
no setter
isBroadcast → bool: Whether this stream is a broadcast stream.
no setteroverride
isEmpty → Future<bool>: Whether this stream contains any elements.
no setteroverride
isEmpty → bool: Available on ReadonlySignal<String>, provided by the StringSignalExtension extension
Whether this string is empty.
no setter
isEmpty → bool: Available on ReadonlySignal<Map<K, V>>, provided by the ReadonlyMapSignalExtension extension

no setter
isEmpty → bool: Available on ReadonlySignal<Iterable<E>>, provided by the ReadonlyIterableSignalExtension extension

no setter
isEven → bool: Available on ReadonlySignal<int>, provided by the IntSignalExtension extension
Returns true if and only if this integer is even.
no setter
isFinite → bool: Available on ReadonlySignal<num>, provided by the NumSignalExtension extension
Whether this number is finite.
no setter
isInfinite → bool: Available on ReadonlySignal<num>, provided by the NumSignalExtension extension
Whether this number is positive infinity or negative infinity.
no setter
isInitialized → bool: Check if a signal value is set (does not subscribe)
no setterinherited
isNaN → bool: Available on ReadonlySignal<num>, provided by the NumSignalExtension extension
Whether this number is a Not-a-Number value.
no setter
isNegative → bool: Available on ReadonlySignal<num>, provided by the NumSignalExtension extension
Whether this number is negative.
no setter
isNotEmpty → bool: Available on ReadonlySignal<String>, provided by the StringSignalExtension extension
Whether this string is not empty.
no setter
isNotEmpty → bool: Available on ReadonlySignal<Iterable<E>>, provided by the ReadonlyIterableSignalExtension extension

no setter
isNotEmpty → bool: Available on ReadonlySignal<Map<K, V>>, provided by the ReadonlyMapSignalExtension extension

no setter
isOdd → bool: Available on ReadonlySignal<int>, provided by the IntSignalExtension extension
Returns true if and only if this integer is odd.
no setter
iterator → Iterator<E>: Available on ReadonlySignal<Iterable<E>>, provided by the ReadonlyIterableSignalExtension extension

no setter
keys → Iterable<K>: Available on ReadonlySignal<Map<K, V>>, provided by the ReadonlyMapSignalExtension extension

no setter
last → E: Available on ReadonlySignal<Iterable<E>>, provided by the ReadonlyIterableSignalExtension extension

no setter
last → E: Available on ReadonlySignal<List<E>>, provided by the ReadonlyListSignalExtension extension

no setter
last → Future<T>: The last element of this stream.
no setteroverride
length → int: Available on ReadonlySignal<Iterable<E>>, provided by the ReadonlyIterableSignalExtension extension

no setter
length → int: Available on ReadonlySignal<Map<K, V>>, provided by the ReadonlyMapSignalExtension extension

no setter
length → int: Available on ReadonlySignal<String>, provided by the StringSignalExtension extension
The length of the string.
no setter
length → Future<int>: The number of elements in this stream.
no setteroverride
name → String: Available on ReadonlySignal<Enum>, provided by the EnumSignalExtension extension
The name of the enum value.
no setter
reversed → Iterable<E>: Available on ReadonlySignal<List<E>>, provided by the ReadonlyListSignalExtension extension

no setter
runes → Runes: Available on ReadonlySignal<String>, provided by the StringSignalExtension extension
An Iterable of Unicode code-points of this string.
no setter
runtimeType → Type: A representation of the runtime type of the object.
no setterinherited
sign → int: Available on ReadonlySignal<int>, provided by the IntSignalExtension extension
Returns the sign of this integer.
no setter
sign → double: Available on ReadonlySignal<double>, provided by the DoubleSignalExtension extension
The sign of the double's numerical value.
no setter
sign → num: Available on ReadonlySignal<num>, provided by the NumSignalExtension extension
Negative one, zero or positive one depending on the sign and numerical value of this number.
no setter
single → E: Available on ReadonlySignal<Iterable<E>>, provided by the ReadonlyIterableSignalExtension extension

no setter
single → Future<T>: The single element of this stream.
no setteroverride
value → T: Compute the current value
no setterinherited
values → Iterable<V>: Available on ReadonlySignal<Map<K, V>>, provided by the ReadonlyMapSignalExtension extension

no setter

Methods

abs() → double: Available on ReadonlySignal<double>, provided by the DoubleSignalExtension extension
abs() → num: Available on ReadonlySignal<num>, provided by the NumSignalExtension extension
The absolute value of this number.
abs() → int: Available on ReadonlySignal<int>, provided by the IntSignalExtension extension
Returns the absolute value of this integer.
allMatches(String string, [int start = 0]) → Iterable<Match>: Available on ReadonlySignal<Pattern>, provided by the PatternSignalExtension extension
Matches this pattern against the string repeatedly.
any(bool test(T element)) → Future<bool>: Checks whether test accepts any element provided by this stream.
override
any(bool test(E element)) → bool: Available on ReadonlySignal<Iterable<E>>, provided by the ReadonlyIterableSignalExtension extension
asBroadcastStream({void onListen(StreamSubscription<T> subscription)?, void onCancel(StreamSubscription<T> subscription)?}) → Stream<T>: Returns a multi-subscription stream that produces the same events as this.
override
asMap() → Map<int, E>: Available on ReadonlySignal<List<E>>, provided by the ReadonlyListSignalExtension extension
asPausable() → PausableStream<T>: Available on Stream<T>, provided by the StreamTransformations extension
Returns a pausable version of this stream.
asyncExpand<E>(Stream<E>? convert(T event)) → Stream<E>: Transforms each element into a sequence of asynchronous events.
override
asyncMap<E>(FutureOr<E> convert(T event)) → Stream<E>: Creates a new stream with each data event of this stream asynchronously mapped to a new event.
override
buffer(Stream<void> window) → Stream<List<T>>: Available on Stream<T>, provided by the BufferExtensions extension
Creates a Stream where each item is a List containing the items from the source sequence.
bufferCount(int count, [int startBufferEvery = 0]) → Stream<List<T>>: Available on Stream<T>, provided by the BufferExtensions extension
Buffers a number of values from the source Stream by count then emits the buffer and clears it, and starts a new buffer each startBufferEvery values. If startBufferEvery is not provided, then new buffers are started immediately at the start of the source and when each buffer closes and is emitted.
bufferCount(int count) → Stream<List<T>>: Available on Stream<T>, provided by the StreamTransformations extension
Buffers incoming events into lists of size count.
bufferTest(bool onTestHandler(T event)) → Stream<List<T>>: Available on Stream<T>, provided by the BufferExtensions extension
Creates a Stream where each item is a List containing the items from the source sequence, batched whenever test passes.
bufferTime(Duration duration) → Stream<List<T>>: Available on Stream<T>, provided by the BufferExtensions extension
Creates a Stream where each item is a List containing the items from the source sequence, sampled on a time frame with duration.
call() → T: Return the value when invoked
inherited
cast<R>() → Set<R>: Available on ReadonlySignal<Set<E>>, provided by the ReadonlySetSignalExtension extension
cast<R>() → Stream<R>: Adapt this stream to be a Stream<R>.
override
cast<R>() → Iterable<R>: Available on ReadonlySignal<Iterable<E>>, provided by the ReadonlyIterableSignalExtension extension
cast<R>() → List<R>: Available on ReadonlySignal<List<E>>, provided by the ReadonlyListSignalExtension extension
cast<RK, RV>() → Map<RK, RV>: Available on ReadonlySignal<Map<K, V>>, provided by the ReadonlyMapSignalExtension extension
ceil() → int: Available on ReadonlySignal<int>, provided by the IntSignalExtension extension
Returns this.
ceil() → int: Available on ReadonlySignal<double>, provided by the DoubleSignalExtension extension
Returns the least integer that is not smaller than this number.
ceil() → int: Available on ReadonlySignal<num>, provided by the NumSignalExtension extension
The least integer no smaller than this.
ceilToDouble() → double: Available on ReadonlySignal<double>, provided by the DoubleSignalExtension extension
Returns the least integer double value no smaller than this.
ceilToDouble() → double: Available on ReadonlySignal<int>, provided by the IntSignalExtension extension
Returns this.toDouble().
ceilToDouble() → double: Available on ReadonlySignal<num>, provided by the NumSignalExtension extension
Returns the least double integer value no smaller than this.
clamp(num lowerLimit, num upperLimit) → num: Available on ReadonlySignal<num>, provided by the NumSignalExtension extension
Returns this num clamped to be in the range lowerLimit-upperLimit.
codeUnitAt(int index) → int: Available on ReadonlySignal<String>, provided by the StringSignalExtension extension
Returns the 16-bit UTF-16 code unit at the given index.
compareTo(T other) → int: Available on ReadonlySignal<T>, provided by the ComparableSignalExtension extension
Compares this object to another object.
completeOnError() → Stream<T>: Available on Stream<T>, provided by the StreamErrorRecovery extension
Completes the stream immediately upon an error, swallowing the error.
concatWith(Iterable<Stream<T>> other) → Stream<T>: Available on Stream<T>, provided by the ConcatExtensions extension
Returns a Stream that emits all items from the current Stream, then emits all items from the given streams, one after the next.
contains(Object? value) → bool: Available on ReadonlySignal<Iterable<E>>, provided by the ReadonlyIterableSignalExtension extension
contains(Object? needle) → Future<bool>: Returns whether needle occurs in the elements provided by this stream.
override
contains(Pattern other, [int startIndex = 0]) → bool: Available on ReadonlySignal<String>, provided by the StringSignalExtension extension
Whether this string contains a match of other.
containsAll(Iterable<Object?> other) → bool: Available on ReadonlySignal<Set<E>>, provided by the ReadonlySetSignalExtension extension
containsKey(Object? key) → bool: Available on ReadonlySignal<Map<K, V>>, provided by the ReadonlyMapSignalExtension extension
containsValue(Object? value) → bool: Available on ReadonlySignal<Map<K, V>>, provided by the ReadonlyMapSignalExtension extension
debounce(Stream<void> window(T event)) → Stream<T>: Available on Stream<T>, provided by the DebounceExtensions extension
Transforms a Stream so that will only emit items from the source sequence if a window has completed, without the source sequence emitting another item.
debounceTime(Duration duration) → Stream<T>: Available on Stream<T>, provided by the DebounceExtensions extension
Transforms a Stream so that will only emit items from the source sequence whenever the time span defined by duration passes, without the source sequence emitting another item.
defaultIfEmpty(T defaultValue) → Stream<T>: Available on Stream<T>, provided by the DefaultIfEmptyExtension extension
Emit items from the source Stream, or a single default item if the source Stream emits nothing.
delay(Duration duration) → Stream<T>: Available on Stream<T>, provided by the DelayExtension extension
The Delay operator modifies its source Stream by pausing for a particular increment of time (that you specify) before emitting each of the source Stream’s items. This has the effect of shifting the entire sequence of items emitted by the Stream forward in time by that specified increment.
delayWhen(Stream<void> itemDelaySelector(T value), {Stream<void>? listenDelay}) → Stream<T>: Available on Stream<T>, provided by the DelayWhenExtension extension
Delays the emission of items from the source Stream by a given time span determined by the emissions of another Stream.
dematerialize() → Stream<T>: Available on Stream<StreamNotification<T>>, provided by the DematerializeExtension extension
Converts the onData, onDone, and onError StreamNotification objects from a materialized stream into normal onData, onDone, and onError events.
difference(Set<Object?> other) → Set<E>: Available on ReadonlySignal<Set<E>>, provided by the ReadonlySetSignalExtension extension
dispose() → void: Dispose the signal
override
distinct([bool equals(T previous, T next)?]) → Stream<T>: Skips data events if they are equal to the previous data event.
override
distinctUnique({bool equals(T e1, T e2)?, int hashCode(T e)?}) → Stream<T>: Available on Stream<T>, provided by the DistinctUniqueExtension extension
WARNING: More commonly known as distinct in other Rx implementations. Creates a Stream where data events are skipped if they have already been emitted before.
doOnCancel(FutureOr<void> onCancel()) → Stream<T>: Available on Stream<T>, provided by the DoExtensions extension
Invokes the given callback function when the stream subscription is cancelled. Often called doOnUnsubscribe or doOnDispose in other implementations.
doOnData(void onData(T event)) → Stream<T>: Available on Stream<T>, provided by the DoExtensions extension
Invokes the given callback function when the stream emits an item. In other implementations, this is called doOnNext.
doOnDone(void onDone()) → Stream<T>: Available on Stream<T>, provided by the DoExtensions extension
Invokes the given callback function when the stream finishes emitting items. In other implementations, this is called doOnComplete(d).
doOnEach(void onEach(StreamNotification<T> notification)) → Stream<T>: Available on Stream<T>, provided by the DoExtensions extension
Invokes the given callback function when the stream emits data, emits an error, or emits done. The callback receives a StreamNotification object.
doOnError(void onError(Object, StackTrace)) → Stream<T>: Available on Stream<T>, provided by the DoExtensions extension
Invokes the given callback function when the stream emits an error.
doOnListen(void onListen()) → Stream<T>: Available on Stream<T>, provided by the DoExtensions extension
Invokes the given callback function when the stream is first listened to.
doOnPause(void onPause()) → Stream<T>: Available on Stream<T>, provided by the DoExtensions extension
Invokes the given callback function when the stream subscription is paused.
doOnResume(void onResume()) → Stream<T>: Available on Stream<T>, provided by the DoExtensions extension
Invokes the given callback function when the stream subscription resumes receiving items.
drain<E>([E? futureValue]) → Future<E>: Discards all data on this stream, but signals when it is done or an error occurred.
override
elementAt(int index) → Future<T>: Returns the value of the indexth data event of this stream.
override
elementAt(int index) → E: Available on ReadonlySignal<Iterable<E>>, provided by the ReadonlyIterableSignalExtension extension
endsWith(String other) → bool: Available on ReadonlySignal<String>, provided by the StringSignalExtension extension
Whether this string ends with other.
endWith(T endValue) → Stream<T>: Available on Stream<T>, provided by the EndWithExtension extension
Appends a value to the source Stream before closing.
endWithMany(Iterable<T> endValues) → Stream<T>: Available on Stream<T>, provided by the EndWithManyExtension extension
Appends a sequence of values as final events to the source Stream before closing.
every(bool test(E element)) → bool: Available on ReadonlySignal<Iterable<E>>, provided by the ReadonlyIterableSignalExtension extension
every(bool test(T element)) → Future<bool>: Checks whether test accepts all elements provided by this stream.
override
exhaustMap<S>(Stream<S> mapper(T value)) → Stream<S>: Available on Stream<T>, provided by the ExhaustMapExtension extension
Converts items from the source stream into a Stream using a given mapper. It ignores all items from the source stream until the new stream completes.
expand<R>(Iterable<R> toElements(E element)) → Iterable<R>: Available on ReadonlySignal<Iterable<E>>, provided by the ReadonlyIterableSignalExtension extension
expand<R>(Iterable<R> toElements(E element)) → Iterable<R>: Available on ReadonlySignal<List<E>>, provided by the ReadonlyListSignalExtension extension
expand<S>(Iterable<S> convert(T element)) → Stream<S>: Transforms each element of this stream into a sequence of elements.
override
firstWhere(bool test(E element), {E orElse()?}) → E: Available on ReadonlySignal<Iterable<E>>, provided by the ReadonlyIterableSignalExtension extension
firstWhere(bool test(E element), {E orElse()?}) → E: Available on ReadonlySignal<List<E>>, provided by the ReadonlyListSignalExtension extension
firstWhere(bool test(T element), {T orElse()?}) → Future<T>: Finds the first element of this stream matching test.
override
flatMap<S>(Stream<S> mapper(T value), {int? maxConcurrent}) → Stream<S>: Available on Stream<T>, provided by the FlatMapExtension extension
Converts each emitted item into a Stream using the given mapper function, while limiting the maximum number of concurrent subscriptions to these Streams. The newly created Stream will be be listened to and begin emitting items downstream.
flatMapIterable<S>(Stream<Iterable<S>> mapper(T value), {int? maxConcurrent}) → Stream<S>: Available on Stream<T>, provided by the FlatMapExtension extension
Converts each item into a Stream. The Stream must return an Iterable. Then, each item from the Iterable will be emitted one by one.
floor() → int: Available on ReadonlySignal<double>, provided by the DoubleSignalExtension extension
Returns the greatest integer no greater than this number.
floor() → int: Available on ReadonlySignal<int>, provided by the IntSignalExtension extension
Returns this.
floor() → int: Available on ReadonlySignal<num>, provided by the NumSignalExtension extension
The greatest integer no greater than this number.
floorToDouble() → double: Available on ReadonlySignal<num>, provided by the NumSignalExtension extension
Returns the greatest double integer value no greater than this.
floorToDouble() → double: Available on ReadonlySignal<double>, provided by the DoubleSignalExtension extension
Returns the greatest integer double value no greater than this.
floorToDouble() → double: Available on ReadonlySignal<int>, provided by the IntSignalExtension extension
Returns this.toDouble().
fold<R>(R initialValue, R combine(R previousValue, E element)) → R: Available on ReadonlySignal<List<E>>, provided by the ReadonlyListSignalExtension extension
fold<S>(S initialValue, S combine(S previous, T element)) → Future<S>: Combines a sequence of values by repeatedly applying combine.
override
fold<R>(R initialValue, R combine(R previousValue, E element)) → R: Available on ReadonlySignal<Iterable<E>>, provided by the ReadonlyIterableSignalExtension extension
followedBy(Iterable<E> other) → Iterable<E>: Available on ReadonlySignal<List<E>>, provided by the ReadonlyListSignalExtension extension
followedBy(Iterable<E> other) → Iterable<E>: Available on ReadonlySignal<Iterable<E>>, provided by the ReadonlyIterableSignalExtension extension
forEach(void action(T element)) → Future<void>: Executes action on each element of this stream.
override
forEach(void action(E element)) → void: Available on ReadonlySignal<Iterable<E>>, provided by the ReadonlyIterableSignalExtension extension
gcd(int other) → int: Available on ReadonlySignal<int>, provided by the IntSignalExtension extension
Returns the greatest common divisor of this integer and other.
get() → T: Helper method to get the current value
inherited
getRange(int start, int end) → Iterable<E>: Available on ReadonlySignal<List<E>>, provided by the ReadonlyListSignalExtension extension
groupBy<K>(K grouper(T value), {Stream<void> durationSelector(GroupedStream<T, K> grouped)?}) → Stream<GroupedStream<T, K>>: Available on Stream<T>, provided by the GroupByExtension extension
The GroupBy operator divides a Stream that emits items into a Stream that emits GroupedStream, each one of which emits some subset of the items from the original source Stream.
handleError(Function onError, {bool test(dynamic error)?}) → Stream<T>: Creates a wrapper Stream that intercepts some errors from this stream.
override
ignoreElements() → Stream<Never>: Available on Stream<T>, provided by the IgnoreElementsExtension extension
Creates a Stream where all emitted items are ignored, only the error / completed notifications are passed
indexOf(Pattern pattern, [int start = 0]) → int: Available on ReadonlySignal<String>, provided by the StringSignalExtension extension
Returns the position of the first match of pattern in this string, starting at start, inclusive:
indexOf(E element, [int start = 0]) → int: Available on ReadonlySignal<List<E>>, provided by the ReadonlyListSignalExtension extension
indexWhere(bool test(E element), [int start = 0]) → int: Available on ReadonlySignal<List<E>>, provided by the ReadonlyListSignalExtension extension
intersection(Set<Object?> other) → Set<E>: Available on ReadonlySignal<Set<E>>, provided by the ReadonlySetSignalExtension extension
interval(Duration duration) → Stream<T>: Available on Stream<T>, provided by the IntervalExtension extension
Creates a Stream that emits each item in the Stream after a given duration.
join([String separator = ""]) → String: Available on ReadonlySignal<Iterable<E>>, provided by the ReadonlyIterableSignalExtension extension
join([String separator = ""]) → Future<String>: Combines the string representation of elements into a single string.
override
lastIndexOf(E element, [int? start]) → int: Available on ReadonlySignal<List<E>>, provided by the ReadonlyListSignalExtension extension
lastIndexOf(Pattern pattern, [int? start]) → int: Available on ReadonlySignal<String>, provided by the StringSignalExtension extension
The starting position of the last match pattern in this string.
lastIndexWhere(bool test(E element), [int? start]) → int: Available on ReadonlySignal<List<E>>, provided by the ReadonlyListSignalExtension extension
lastWhere(bool test(T element), {T orElse()?}) → Future<T>: Finds the last element in this stream matching test.
override
lastWhere(bool test(E element), {E orElse()?}) → E: Available on ReadonlySignal<Iterable<E>>, provided by the ReadonlyIterableSignalExtension extension
listen(void onData(T event)?, {Function? onError, void onDone()?, bool? cancelOnError}) → StreamSubscription<T>: Adds a subscription to this stream.
override
lookup(Object? object) → E?: Available on ReadonlySignal<Set<E>>, provided by the ReadonlySetSignalExtension extension
map<S>(S convert(T event)) → Stream<S>: Transforms each element of this stream into a new stream event.
override
map<R>(R toElement(E e)) → Iterable<R>: Available on ReadonlySignal<Iterable<E>>, provided by the ReadonlyIterableSignalExtension extension
map<K2, V2>(MapEntry<K2, V2> convert(K key, V value)) → Map<K2, V2>: Available on ReadonlySignal<Map<K, V>>, provided by the ReadonlyMapSignalExtension extension
mapNotNull<R extends Object>(R? transform(T)) → Stream<R>: Available on Stream<T>, provided by the MapNotNullExtension extension
Returns a Stream containing only the non-null results of applying the given transform function to each element of this Stream.
mapTo<T>(T value) → Stream<T>: Available on Stream<S>, provided by the MapToExtension extension
Emits the given constant value on the output Stream every time the source Stream emits a value.
matchAsPrefix(String string, [int start = 0]) → Match?: Available on ReadonlySignal<Pattern>, provided by the PatternSignalExtension extension
Matches this pattern against the start of string.
materialize() → Stream<StreamNotification<T>>: Available on Stream<T>, provided by the MaterializeExtension extension
Converts the onData, on Done, and onError events into StreamNotification objects that are passed into the downstream onData listener.
max([Comparator<T>? comparator]) → Future<T>: Available on Stream<T>, provided by the MaxExtension extension
Converts a Stream into a Future that completes with the largest item emitted by the Stream.
mergeWith(Iterable<Stream<T>> streams) → Stream<T>: Available on Stream<T>, provided by the MergeExtension extension
Combines the items emitted by multiple streams into a single stream of items. The items are emitted in the order they are emitted by their sources.
min([Comparator<T>? comparator]) → Future<T>: Available on Stream<T>, provided by the MinExtension extension
Converts a Stream into a Future that completes with the smallest item emitted by the Stream.
modInverse(int modulus) → int: Available on ReadonlySignal<int>, provided by the IntSignalExtension extension
Returns the modular multiplicative inverse of this integer modulo modulus.
modPow(int exponent, int modulus) → int: Available on ReadonlySignal<int>, provided by the IntSignalExtension extension
Returns this integer to the power of exponent modulo modulus.
noSuchMethod(Invocation invocation) → dynamic: Invoked when a nonexistent method or property is accessed.
inherited
observe(Widget builder(T), {Key? key, void onInit(T value)?, Function? onValueUpdated, void onAfterBuild(T value)?, void onDispose(T value)?, bool shouldRebuild(T newValue, T oldValue)?, bool shouldNotify(T newValue, T oldValue)?, bool equals(T a, T b)?, Duration? debounce, Duration? throttle, void onError(Object error, StackTrace stack)?, Widget errorBuilder(Object error)?, Widget loadingBuilder()?, String? debugLabel, bool debugPrint = false}) → SignalsWatch<T>: Available on ReadonlySignal<T>, provided by the SignalObserveExtension extension
Observe this signal and rebuild when it changes.
onDispose(void cleanup()) → void Function(): Add a cleanup function to be called when the signal is disposed
inherited
onErrorResume(Stream<T> recoveryFn(Object error, StackTrace stackTrace)) → Stream<T>: Available on Stream<T>, provided by the OnErrorExtensions extension
Intercepts error events and switches to a recovery stream created by the provided recoveryFn.
onErrorResumeNext(Stream<T> recoveryStream) → Stream<T>: Available on Stream<T>, provided by the OnErrorExtensions extension
Intercepts error events and switches to the given recovery stream in that case
onErrorReturn(T returnValue) → Stream<T>: Available on Stream<T>, provided by the OnErrorExtensions extension
Instructs a Stream to emit a particular item when it encounters an error, and then terminate normally
onErrorReturnWith(T returnFn(Object error, StackTrace stackTrace)) → Stream<T>: Available on Stream<T>, provided by the OnErrorExtensions extension
Instructs a Stream to emit a particular item created by the returnFn when it encounters an error, and then terminate normally.
padLeft(int width, [String padding = ' ']) → String: Available on ReadonlySignal<String>, provided by the StringSignalExtension extension
Pads this string on the left if it is shorter than width.
padRight(int width, [String padding = ' ']) → String: Available on ReadonlySignal<String>, provided by the StringSignalExtension extension
Pads this string on the right if it is shorter than width.
pairwise() → Stream<List<T>>: Available on Stream<T>, provided by the PairwiseExtension extension
Emits the n-th and n-1th events as a pair. The first event won't be emitted until the second one arrives.
peek() → T: In the rare instance that you have an effect that should write to another signal based on the previous value, but you don't want the effect to be subscribed to that signal, you can read a signals's previous value via signal.peek().
inherited
pipe(StreamConsumer<T> streamConsumer) → Future: Pipes the events of this stream into streamConsumer.
override
publish() → PublishConnectableStream<T>: Available on Stream<T>, provided by the ConnectableStreamExtensions extension
Convert the current Stream into a ConnectableStream that can be listened to multiple times. It will not begin emitting items from the original Stream until the connect method is invoked.
publishReplay({int? maxSize}) → ReplayConnectableStream<T>: Available on Stream<T>, provided by the ConnectableStreamExtensions extension
Convert the current Stream into a ReplayConnectableStream that can be listened to multiple times. It will not begin emitting items from the original Stream until the connect method is invoked.
publishValue() → ValueConnectableStream<T>: Available on Stream<T>, provided by the ConnectableStreamExtensions extension
Convert the current Stream into a ValueConnectableStream that can be listened to multiple times. It will not begin emitting items from the original Stream until the connect method is invoked.
publishValueSeeded(T seedValue) → ValueConnectableStream<T>: Available on Stream<T>, provided by the ConnectableStreamExtensions extension
Convert the current Stream into a ValueConnectableStream that can be listened to multiple times, providing an initial seeded value. It will not begin emitting items from the original Stream until the connect method is invoked.
rateLimit(int maxEvents, Duration duration) → Stream<T>: Available on Stream<T>, provided by the StreamTransformations extension
Limits the rate of event emissions, allowing at most maxEvents during each duration window.
reduce(T combine(T previous, T element)) → Future<T>: Combines a sequence of values by repeatedly applying combine.
override
reduce(E combine(E value, E element)) → E: Available on ReadonlySignal<Iterable<E>>, provided by the ReadonlyIterableSignalExtension extension
remainder(num other) → num: Available on ReadonlySignal<num>, provided by the NumSignalExtension extension
The remainder of the truncating division of this by other.
remainder(num other) → double: Available on ReadonlySignal<double>, provided by the DoubleSignalExtension extension
replaceAll(Pattern from, String replace) → String: Available on ReadonlySignal<String>, provided by the StringSignalExtension extension
Replaces all substrings that match from with replace.
replaceAllMapped(Pattern from, String replace(Match match)) → String: Available on ReadonlySignal<String>, provided by the StringSignalExtension extension
Replace all substrings that match from by a computed string.
replaceFirst(Pattern from, String to, [int startIndex = 0]) → String: Available on ReadonlySignal<String>, provided by the StringSignalExtension extension
Creates a new string with the first occurrence of from replaced by to.
replaceFirstMapped(Pattern from, String replace(Match match), [int startIndex = 0]) → String: Available on ReadonlySignal<String>, provided by the StringSignalExtension extension
Replace the first occurrence of from in this string.
replaceOnError({required T defaultValue}) → Stream<T>: Available on Stream<T>, provided by the StreamErrorRecovery extension
Replaces an error event with defaultValue and then completes the stream.
replaceRange(int start, int? end, String replacement) → String: Available on ReadonlySignal<String>, provided by the StringSignalExtension extension
Replaces the substring from start to end with replacement.
retry({int retryCount = 3, Duration delayFactor = const Duration(seconds: 1), bool shouldRetry(Object error)?}) → Stream<T>: Available on Stream<T>, provided by the StreamErrorRecovery extension
Retries the stream subscription in case of error.
round() → int: Available on ReadonlySignal<num>, provided by the NumSignalExtension extension
The integer closest to this number.
round() → int: Available on ReadonlySignal<double>, provided by the DoubleSignalExtension extension
Returns the integer closest to this number.
round() → int: Available on ReadonlySignal<int>, provided by the IntSignalExtension extension
Returns this.
roundToDouble() → double: Available on ReadonlySignal<num>, provided by the NumSignalExtension extension
The double integer value closest to this value.
roundToDouble() → double: Available on ReadonlySignal<int>, provided by the IntSignalExtension extension
Returns this.toDouble().
roundToDouble() → double: Available on ReadonlySignal<double>, provided by the DoubleSignalExtension extension
Returns the integer double value closest to this.
sample(Stream sampleStream) → Stream<T>: Available on Stream<T>, provided by the SampleExtensions extension
Emits the most recently emitted item (if any) emitted by the source Stream since the previous emission from the sampleStream.
sampleTime(Duration duration) → Stream<T>: Available on Stream<T>, provided by the SampleExtensions extension
Emits the most recently emitted item (if any) emitted by the source Stream since the previous emission within the recurring time span, defined by duration
scan<S>(S accumulator(S accumulated, T value, int index), S seed) → Stream<S>: Available on Stream<T>, provided by the ScanExtension extension
Applies an accumulator function over a Stream sequence and returns each intermediate result. The seed value is used as the initial accumulator value.
select<R>(R selector(ReadonlySignal<T>), {bool? autoDispose = false, String? debugLabel}) → Computed<R>: Available on ReadonlySignal<T>, provided by the ReadonlySignalUtils extension
Select a value and return a computed signal to listen for changes
selectObserve<S>(S selector(dynamic), Widget builder(S), {Key? key, void onInit(S value)?, Function? onValueUpdated, void onAfterBuild(S value)?, void onDispose(S value)?, bool shouldRebuild(S newValue, S oldValue)?, bool shouldNotify(S newValue, S oldValue)?, bool equals(S a, S b)?, Duration? debounce, Duration? throttle, void onError(Object error, StackTrace stack)?, Widget errorBuilder(Object error)?, Widget loadingBuilder()?, String? debugLabel, bool debugPrint = false}) → SignalsWatch<S>: Available on ReadonlySignal<T>, provided by the SignalObserveExtension extension
Select a specific part of this signal's value and only rebuild when that part changes.
share() → Stream<T>: Available on Stream<T>, provided by the ConnectableStreamExtensions extension
Convert the current Stream into a new Stream that can be listened to multiple times. It will automatically begin emitting items when first listened to, and shut down when no listeners remain.
shareReplay({int? maxSize}) → ReplayStream<T>: Available on Stream<T>, provided by the ConnectableStreamExtensions extension
Convert the current Stream into a new ReplayStream that can be listened to multiple times. It will automatically begin emitting items when first listened to, and shut down when no listeners remain.
shareValue() → ValueStream<T>: Available on Stream<T>, provided by the ConnectableStreamExtensions extension
Convert the current Stream into a new ValueStream that can be listened to multiple times. It will automatically begin emitting items when first listened to, and shut down when no listeners remain.
shareValueSeeded(T seedValue) → ValueStream<T>: Available on Stream<T>, provided by the ConnectableStreamExtensions extension
Convert the current Stream into a new ValueStream that can be listened to multiple times, providing an initial value. It will automatically begin emitting items when first listened to, and shut down when no listeners remain.
singleWhere(bool test(E element), {E orElse()?}) → E: Available on ReadonlySignal<Iterable<E>>, provided by the ReadonlyIterableSignalExtension extension
singleWhere(bool test(T element), {T orElse()?}) → Future<T>: Finds the single element in this stream matching test.
override
skip(int count) → Stream<T>: Skips the first count data events from this stream.
override
skip(int count) → Iterable<E>: Available on ReadonlySignal<Iterable<E>>, provided by the ReadonlyIterableSignalExtension extension
skipLast(int count) → Stream<T>: Available on Stream<T>, provided by the SkipLastExtension extension
Starts emitting every items except last count items. This causes items to be delayed.
skipUntil<S>(Stream<S> otherStream) → Stream<T>: Available on Stream<T>, provided by the SkipUntilExtension extension
Starts emitting items only after the given stream emits an item.
skipWhile(bool test(E value)) → Iterable<E>: Available on ReadonlySignal<Iterable<E>>, provided by the ReadonlyIterableSignalExtension extension
skipWhile(bool test(T element)) → Stream<T>: Skip data events from this stream while they are matched by test.
override
sorted([int compare(E a, E b)?]) → List<E>: Available on ReadonlySignal<List<E>>, provided by the ReadonlyListSignalExtension extension
Return a new array that is sorted by the compare function
split(Pattern pattern) → List<String>: Available on ReadonlySignal<String>, provided by the StringSignalExtension extension
Splits the string at matches of pattern and returns a list of substrings.
splitMapJoin(Pattern pattern, {String onMatch(Match)?, String onNonMatch(String)?}) → String: Available on ReadonlySignal<String>, provided by the StringSignalExtension extension
Splits the string, converts its parts, and combines them into a new string.
startsWith(Pattern pattern, [int index = 0]) → bool: Available on ReadonlySignal<String>, provided by the StringSignalExtension extension
Whether this string starts with a match of pattern.
startWith(T startValue) → Stream<T>: Available on Stream<T>, provided by the StartWithExtension extension
Prepends a value to the source Stream.
startWithMany(List<T> startValues) → Stream<T>: Available on Stream<T>, provided by the StartWithManyExtension extension
Prepends a sequence of values to the source Stream.
sublist(int start, [int? end]) → List<E>: Available on ReadonlySignal<List<E>>, provided by the ReadonlyListSignalExtension extension
subscribe(void fn(T value)) → void Function(): Subscribe to value changes with a dispose function
inherited
substring(int start, [int? end]) → String: Available on ReadonlySignal<String>, provided by the StringSignalExtension extension
The substring of this string from start, inclusive, to end, exclusive.
switchIfEmpty(Stream<T> fallbackStream) → Stream<T>: Available on Stream<T>, provided by the SwitchIfEmptyExtension extension
When the original Stream emits no items, this operator subscribes to the given fallback stream and emits items from that Stream instead.
switchMap<S>(Stream<S> mapper(T value)) → Stream<S>: Available on Stream<T>, provided by the SwitchMapExtension extension
Converts each emitted item into a Stream using the given mapper function. The newly created Stream will be be listened to and begin emitting items, and any previously created Stream will stop emitting.
take(int count) → Iterable<E>: Available on ReadonlySignal<Iterable<E>>, provided by the ReadonlyIterableSignalExtension extension
take(int count) → Stream<T>: Provides at most the first count data events of this stream.
override
takeLast(int count) → Stream<T>: Available on Stream<T>, provided by the TakeLastExtension extension
Emits only the final count values emitted by the source Stream.
takeUntil<S>(Stream<S> otherStream) → Stream<T>: Available on Stream<T>, provided by the TakeUntilExtension extension
Returns the values from the source Stream sequence until the other Stream sequence produces a value.
takeWhile(bool test(E value)) → Iterable<E>: Available on ReadonlySignal<Iterable<E>>, provided by the ReadonlyIterableSignalExtension extension
takeWhile(bool test(T element)) → Stream<T>: Forwards data events while test is successful.
override
takeWhileInclusive(bool test(T)) → Stream<T>: Available on Stream<T>, provided by the TakeWhileInclusiveExtension extension
Emits values emitted by the source Stream so long as each value satisfies the given test. When the test is not satisfied by a value, it will emit this value as a final event and then complete.
throttle(Stream<void> window(T event), {bool trailing = false, bool leading = true}) → Stream<T>: Available on Stream<T>, provided by the ThrottleExtensions extension
Emits a value from the source Stream, then ignores subsequent source values while the window Stream is open, then repeats this process.
throttleTime(Duration duration, {bool trailing = false, bool leading = true}) → Stream<T>: Available on Stream<T>, provided by the ThrottleExtensions extension
Emits a value from the source Stream, then ignores subsequent source values for a duration, then repeats this process.
timeInterval() → Stream<TimeInterval<T>>: Available on Stream<T>, provided by the TimeIntervalExtension extension
Records the time interval between consecutive values in a Stream sequence.
timeout(Duration timeLimit, {void onTimeout(EventSink<T> sink)?}) → Stream<T>: Creates a new stream with the same events as this stream.
override
timestamp() → Stream<Timestamped<T>>: Available on Stream<T>, provided by the TimeStampExtension extension
Wraps each item emitted by the source Stream in a Timestamped object that includes the emitted item and the time when the item was emitted.
toDouble() → double: Available on ReadonlySignal<num>, provided by the NumSignalExtension extension
This number as a double.
toInt() → int: Available on ReadonlySignal<num>, provided by the NumSignalExtension extension
Truncates this num to an integer and returns the result as an int.
toJson() → dynamic: Convert value to JSON
inherited
toList({bool growable = true}) → List<E>: Available on ReadonlySignal<Iterable<E>>, provided by the ReadonlyIterableSignalExtension extension
toList() → Future<List<T>>: Collects all elements of this stream in a List.
override
toLowerCase() → String: Available on ReadonlySignal<String>, provided by the StringSignalExtension extension
Converts all characters in this string to lower case.
toRadixString(int radix) → String: Available on ReadonlySignal<int>, provided by the IntSignalExtension extension
Converts this int to a string representation in the given radix.
toSet() → Set<E>: Available on ReadonlySignal<Iterable<E>>, provided by the ReadonlyIterableSignalExtension extension
toSet() → Future<Set<T>>: Collects the data of this stream in a Set.
override
toSigned(int width) → int: Available on ReadonlySignal<int>, provided by the IntSignalExtension extension
Returns the least significant width bits of this integer, extending the highest retained bit to the sign. This is the same as truncating the value to fit in width bits using an signed 2-s complement representation. The returned value has the same bit value in all positions higher than width.
toStream() → Stream<T>: Available on ReadonlySignal<T>, provided by the ReadonlySignalUtils extension
Convert a signal to a Stream to be consumed as a read only stream.
toStreamSignal({bool? cancelOnError, String? debugLabel, T? initialValue, bool autoDispose = false, bool lazy = true, List<ReadonlySignal> dependencies = const [], void onDone()?}) → StreamSignal<T>: Available on Stream<T>, provided by the SignalStreamUtils extension
Convert a stream to a signal
toString() → String: A string representation of this object.
inherited
toStringAsExponential([int? fractionDigits]) → String: Available on ReadonlySignal<num>, provided by the NumSignalExtension extension
An exponential string-representation of this number.
toStringAsFixed(int fractionDigits) → String: Available on ReadonlySignal<num>, provided by the NumSignalExtension extension
A decimal-point string-representation of this number.
toStringAsPrecision(int precision) → String: Available on ReadonlySignal<num>, provided by the NumSignalExtension extension
A string representation with precision significant digits.
toSyncSignal(T initialData) → ReadonlySignal<T>: Available on Stream<T>, provided by the SignalStreamUtils extension
Convert a Stream to ReadonlySignal and provide initial value.
toUnsigned(int width) → int: Available on ReadonlySignal<int>, provided by the IntSignalExtension extension
Returns the least significant width bits of this integer as a non-negative number (i.e. unsigned representation). The returned value has zeros in all bit positions higher than width.
toUpperCase() → String: Available on ReadonlySignal<String>, provided by the StringSignalExtension extension
Converts all characters in this string to upper case.
transform<R>(R transform(T), {Key? key, required Widget builder(R), void onInit(R value)?, Function? onValueUpdated, void onAfterBuild(R value)?, void onDispose(R value)?, bool shouldRebuild(R newValue, R oldValue)?, bool shouldNotify(R newValue, R oldValue)?, bool equals(R a, R b)?, Duration? debounce, Duration? throttle, void onError(Object error, StackTrace stack)?, Widget errorBuilder(Object error)?, Widget loadingBuilder()?, String? debugLabel, bool debugPrint = false}) → SignalsWatch<R>: Available on ReadonlySignal<T>, provided by the SignalObserveExtension extension
Transform this signal's value and observe the result with error handling.
transform<S>(StreamTransformer<T, S> streamTransformer) → Stream<S>: Applies streamTransformer to this stream.
override
trim() → String: Available on ReadonlySignal<String>, provided by the StringSignalExtension extension
The string without any leading and trailing whitespace.
trimLeft() → String: Available on ReadonlySignal<String>, provided by the StringSignalExtension extension
The string without any leading whitespace.
trimRight() → String: Available on ReadonlySignal<String>, provided by the StringSignalExtension extension
The string without any trailing whitespace.
truncate() → int: Available on ReadonlySignal<double>, provided by the DoubleSignalExtension extension
Returns the integer obtained by discarding any fractional part of this number.
truncate() → int: Available on ReadonlySignal<int>, provided by the IntSignalExtension extension
Returns this.
truncate() → int: Available on ReadonlySignal<num>, provided by the NumSignalExtension extension
The integer obtained by discarding any fractional digits from this.
truncateToDouble() → double: Available on ReadonlySignal<int>, provided by the IntSignalExtension extension
Returns this.toDouble().
truncateToDouble() → double: Available on ReadonlySignal<num>, provided by the NumSignalExtension extension
Returns the double integer value obtained by discarding any fractional digits from the double value of this.
truncateToDouble() → double: Available on ReadonlySignal<double>, provided by the DoubleSignalExtension extension
Returns the integer double value obtained by discarding any fractional digits from this.
union(Set<E> other) → Set<E>: Available on ReadonlySignal<Set<E>>, provided by the ReadonlySetSignalExtension extension
unwatch(BuildContext context) → void: Available on ReadonlySignal<T>, provided by the FlutterReadonlySignalUtils extension
Stop subscriptions to updates on a signal for watchers
watch(BuildContext context, {String? debugLabel}) → T: Available on ReadonlySignal<T>, provided by the FlutterReadonlySignalUtils extension
Rebuild the Element that the current signal is inside of
where(bool test(E element)) → Iterable<E>: Available on ReadonlySignal<Iterable<E>>, provided by the ReadonlyIterableSignalExtension extension
where(bool test(T event)) → Stream<T>: Creates a new stream from this stream that discards some elements.
override
whereNotNull() → Stream<T>: Available on Stream<T?>, provided by the WhereNotNullExtension extension
Returns a Stream which emits all the non-null elements of this Stream, in their original emission order.
whereType<R>() → Iterable<R>: Available on ReadonlySignal<Iterable<E>>, provided by the ReadonlyIterableSignalExtension extension
whereType<S>() → Stream<S>: Available on Stream<T>, provided by the WhereTypeExtension extension
This transformer is a shorthand for Stream.where followed by Stream.cast.
window(Duration windowDuration) → Stream<List<T>>: Available on Stream<T>, provided by the StreamTransformations extension
Buffers events into time-based windows defined by windowDuration.
window(Stream<void> window) → Stream<Stream<T>>: Available on Stream<T>, provided by the WindowExtensions extension
Creates a Stream where each item is a Stream containing the items from the source sequence.
windowCount(int count, [int startBufferEvery = 0]) → Stream<Stream<T>>: Available on Stream<T>, provided by the WindowExtensions extension
Buffers a number of values from the source Stream by count then emits the buffer as a Stream and clears it, and starts a new buffer each startBufferEvery values. If startBufferEvery is not provided, then new buffers are started immediately at the start of the source and when each buffer closes and is emitted.
windowTest(bool onTestHandler(T event)) → Stream<Stream<T>>: Available on Stream<T>, provided by the WindowExtensions extension
Creates a Stream where each item is a Stream containing the items from the source sequence, batched whenever test passes.
windowTime(Duration duration) → Stream<Stream<T>>: Available on Stream<T>, provided by the WindowExtensions extension
Creates a Stream where each item is a Stream containing the items from the source sequence, sampled on a time frame with duration.
withLatestFrom<S, R>(Stream<S> latestFromStream, R fn(T t, S s)) → Stream<R>: Available on Stream<T>, provided by the WithLatestFromExtensions extension
Creates a Stream that emits when the source stream emits, combining the latest values from the two streams using the provided function.
withLatestFrom2<A, B, R>(Stream<A> latestFromStream1, Stream latestFromStream2, R fn(T t, A a, B b)) → Stream<R>: Available on Stream<T>, provided by the WithLatestFromExtensions extension
Creates a Stream that emits when the source stream emits, combining the latest values from the three streams using the provided function.
withLatestFrom3<A, B, C, R>(Stream<A> latestFromStream1, Stream latestFromStream2, Stream<C> latestFromStream3, R fn(T t, A a, B b, C c)) → Stream<R>: Available on Stream<T>, provided by the WithLatestFromExtensions extension
Creates a Stream that emits when the source stream emits, combining the latest values from the four streams using the provided function.
withLatestFrom4<A, B, C, D, R>(Stream<A> latestFromStream1, Stream latestFromStream2, Stream<C> latestFromStream3, Stream<D> latestFromStream4, R fn(T t, A a, B b, C c, D d)) → Stream<R>: Available on Stream<T>, provided by the WithLatestFromExtensions extension
Creates a Stream that emits when the source stream emits, combining the latest values from the five streams using the provided function.
withLatestFrom5<A, B, C, D, E, R>(Stream<A> latestFromStream1, Stream latestFromStream2, Stream<C> latestFromStream3, Stream<D> latestFromStream4, Stream<E> latestFromStream5, R fn(T t, A a, B b, C c, D d, E e)) → Stream<R>: Available on Stream<T>, provided by the WithLatestFromExtensions extension
Creates a Stream that emits when the source stream emits, combining the latest values from the six streams using the provided function.
withLatestFrom6<A, B, C, D, E, F, R>(Stream<A> latestFromStream1, Stream latestFromStream2, Stream<C> latestFromStream3, Stream<D> latestFromStream4, Stream<E> latestFromStream5, Stream<F> latestFromStream6, R fn(T t, A a, B b, C c, D d, E e, F f)) → Stream<R>: Available on Stream<T>, provided by the WithLatestFromExtensions extension
Creates a Stream that emits when the source stream emits, combining the latest values from the seven streams using the provided function.
withLatestFrom7<A, B, C, D, E, F, G, R>(Stream<A> latestFromStream1, Stream latestFromStream2, Stream<C> latestFromStream3, Stream<D> latestFromStream4, Stream<E> latestFromStream5, Stream<F> latestFromStream6, Stream<G> latestFromStream7, R fn(T t, A a, B b, C c, D d, E e, F f, G g)) → Stream<R>: Available on Stream<T>, provided by the WithLatestFromExtensions extension
Creates a Stream that emits when the source stream emits, combining the latest values from the eight streams using the provided function.
withLatestFrom8<A, B, C, D, E, F, G, H, R>(Stream<A> latestFromStream1, Stream latestFromStream2, Stream<C> latestFromStream3, Stream<D> latestFromStream4, Stream<E> latestFromStream5, Stream<F> latestFromStream6, Stream<G> latestFromStream7, Stream<H> latestFromStream8, R fn(T t, A a, B b, C c, D d, E e, F f, G g, H h)) → Stream<R>: Available on Stream<T>, provided by the WithLatestFromExtensions extension
Creates a Stream that emits when the source stream emits, combining the latest values from the nine streams using the provided function.
withLatestFrom9<A, B, C, D, E, F, G, H, I, R>(Stream<A> latestFromStream1, Stream latestFromStream2, Stream<C> latestFromStream3, Stream<D> latestFromStream4, Stream<E> latestFromStream5, Stream<F> latestFromStream6, Stream<G> latestFromStream7, Stream<H> latestFromStream8, Stream latestFromStream9, R fn(T t, A a, B b, C c, D d, E e, F f, G g, H h, I i)) → Stream<R>: Available on Stream<T>, provided by the WithLatestFromExtensions extension
Creates a Stream that emits when the source stream emits, combining the latest values from the ten streams using the provided function.
withLatestFromList(Iterable<Stream<T>> latestFromStreams) → Stream<List<T>>: Available on Stream<T>, provided by the WithLatestFromExtensions extension
Creates a Stream that emits when the source stream emits, combining the latest values from the streams into a list. This is helpful when you need to combine a dynamic number of Streams.
withLatestValue() → Stream<T>: Available on Stream<T>, provided by the StreamTransformations extension
Returns a stream that replays the latest emitted value to new subscribers.
zipWith<S, R>(Stream<S> other, R zipper(T t, S s)) → Stream<R>: Available on Stream<T>, provided by the ZipWithExtension extension
Returns a Stream that combines the current stream together with another stream using a given zipper function.

Operators

operator %(num other) → num: Available on ReadonlySignal<num>, provided by the NumSignalExtension extension
Euclidean modulo of this number by other.
operator %(num other) → double: Available on ReadonlySignal<double>, provided by the DoubleSignalExtension extension
operator &(bool other) → bool: Available on ReadonlySignal<bool>, provided by the BoolSignalExtension extension
The logical conjunction ("and") of this and other.
operator &(int other) → int: Available on ReadonlySignal<int>, provided by the IntSignalExtension extension
Bit-wise and operator.
operator *(num other) → double: Available on ReadonlySignal<double>, provided by the DoubleSignalExtension extension
operator *(int times) → String: Available on ReadonlySignal<String>, provided by the StringSignalExtension extension
Creates a new string by concatenating this string with itself a number of times.
operator *(num other) → num: Available on ReadonlySignal<num>, provided by the NumSignalExtension extension
Multiplies this number by other.
operator +(String other) → String: Available on ReadonlySignal<String>, provided by the StringSignalExtension extension
Creates a new string by concatenating this string with other.
operator +(List<E> other) → List<E>: Available on ReadonlySignal<List<E>>, provided by the ReadonlyListSignalExtension extension
operator +(num other) → double: Available on ReadonlySignal<double>, provided by the DoubleSignalExtension extension
operator +(num other) → num: Available on ReadonlySignal<num>, provided by the NumSignalExtension extension
Adds other to this number.
operator -(num other) → double: Available on ReadonlySignal<double>, provided by the DoubleSignalExtension extension
operator -(num other) → num: Available on ReadonlySignal<num>, provided by the NumSignalExtension extension
Subtracts other from this number.
operator /(num other) → double: Available on ReadonlySignal<double>, provided by the DoubleSignalExtension extension
operator /(num other) → double: Available on ReadonlySignal<num>, provided by the NumSignalExtension extension
Divides this number by other.
operator <(num other) → bool: Available on ReadonlySignal<num>, provided by the NumSignalExtension extension
Whether this number is numerically smaller than other.
operator <<(int shiftAmount) → int: Available on ReadonlySignal<int>, provided by the IntSignalExtension extension
Shift the bits of this integer to the left by shiftAmount.
operator <=(num other) → bool: Available on ReadonlySignal<num>, provided by the NumSignalExtension extension
Whether this number is numerically smaller than or equal to other.
operator ==(Object other) → bool: The equality operator.
inherited
operator >(num other) → bool: Available on ReadonlySignal<num>, provided by the NumSignalExtension extension
Whether this number is numerically greater than other.
operator >=(num other) → bool: Available on ReadonlySignal<num>, provided by the NumSignalExtension extension
Whether this number is numerically greater than or equal to other.
operator >>(int shiftAmount) → int: Available on ReadonlySignal<int>, provided by the IntSignalExtension extension
Shift the bits of this integer to the right by shiftAmount.
operator >>>(int shiftAmount) → int: Available on ReadonlySignal<int>, provided by the IntSignalExtension extension
Bitwise unsigned right shift by shiftAmount bits.
operator [](int index) → E: Available on ReadonlySignal<List<E>>, provided by the ReadonlyListSignalExtension extension
operator [](Object? key) → V?: Available on ReadonlySignal<Map<K, V>>, provided by the ReadonlyMapSignalExtension extension
operator [](int index) → String: Available on ReadonlySignal<String>, provided by the StringSignalExtension extension
The character (as a single-code-unit String) at the given index.
operator ^(int other) → int: Available on ReadonlySignal<int>, provided by the IntSignalExtension extension
Bit-wise exclusive-or operator.
operator ^(bool other) → bool: Available on ReadonlySignal<bool>, provided by the BoolSignalExtension extension
The logical exclusive disjunction ("exclusive or") of this and other.
operator unary-() → num: Available on ReadonlySignal<num>, provided by the NumSignalExtension extension
The negation of this value.
operator unary-() → double: Available on ReadonlySignal<double>, provided by the DoubleSignalExtension extension
operator unary-() → int: Available on ReadonlySignal<int>, provided by the IntSignalExtension extension
Return the negative value of this integer.
operator |(int other) → int: Available on ReadonlySignal<int>, provided by the IntSignalExtension extension
Bit-wise or operator.
operator |(bool other) → bool: Available on ReadonlySignal<bool>, provided by the BoolSignalExtension extension
The logical disjunction ("inclusive or") of this and other.
operator ~() → int: Available on ReadonlySignal<int>, provided by the IntSignalExtension extension
The bit-wise negate operator.
operator ~/(num other) → int: Available on ReadonlySignal<num>, provided by the NumSignalExtension extension
Truncating division operator.
operator ~/(num other) → int: Available on ReadonlySignal<double>, provided by the DoubleSignalExtension extension

StreamSignalMixin<T> mixin

Properties

Methods

Operators

s_packages_extra2 library