rx_streams library

Classes

CombineLatestStream<T, R>
Merges the given Streams into one Stream sequence by using the combiner function whenever any of the source stream sequences emits an item. [...]
ConcatEagerStream<T>
Concatenates all of the specified stream sequences, as long as the previous stream sequence terminated successfully. [...]
ConcatStream<T>
Concatenates all of the specified stream sequences, as long as the previous stream sequence terminated successfully. [...]
DeferStream<T>
The defer factory waits until an observer subscribes to it, and then it creates an Observable with the given factory function. [...]
ErrorAndStacktrace
ErrorStream<T>
Returns an observable sequence that emits an error, then immediately completes. [...]
ForkJoinStream<T, R>
This operator is best used when you have a group of observables and only care about the final emitted value of each. One common use case for this is if you wish to issue multiple requests on page load (or some other event) and only want to take action when a response has been received for all. [...]
MergeStream<T>
Flattens the items emitted by the given streams into a single Observable sequence. [...]
NeverStream<T>
Returns a non-terminating observable sequence, which can be used to denote an infinite duration. [...]
RaceStream<T>
Given two or more source streams, emit all of the items from only the first of these streams to emit an item or notification. [...]
RangeStream
Returns a Stream that emits a sequence of Integers within a specified range. [...]
RepeatStream<T>
Creates a Stream that will recreate and re-listen to the source Stream the specified number of times until the Stream terminates successfully. [...]
RetryStream<T>
Creates a Stream that will recreate and re-listen to the source Stream the specified number of times until the Stream terminates successfully. [...]
RetryWhenStream<T>
Creates a Stream that will recreate and re-listen to the source Stream when the notifier emits a new value. If the source Stream emits an error or it completes, the Stream terminates. [...]
SequenceEqualStream<S, T>
Determine whether two Observables emit the same sequence of items. You can provide an optional equals handler to determine equality. [...]
SwitchLatestStream<T>
Convert a Stream that emits Streams (aka a "Higher Order Stream") into a single Stream that emits the items emitted by the most-recently-emitted of those Streams. [...]
TimerStream<T>
Emits the given value after a specified amount of time. [...]
ZipStream<T, R>
Merges the specified streams into one observable sequence using the given zipper function whenever all of the observable sequences have produced an element at a corresponding index. [...]

Typedefs

RetryWhenStreamFactory(dynamic error, StackTrace stack) → Stream<void>

Exceptions / Errors

RetryError