rx_streams library

Classes

AmbStream<T>
Deprecated: Use RaceStream [...]
CombineLatestStream<T, A, B, C, D, E, F, G, H, I>
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. [...]
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. [...]
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. [...]
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. [...]
TweenStream
Creates a Stream that emits values starting from startValue and incrementing according to the ease type over the duration. [...]
ZipStream<T, A, B, C, D, E, F, G, H, I>
Merges the specified streams into one observable sequence using the given combiner function whenever all of the observable sequences have produced an element at a corresponding index. [...]

Properties

easeIn Sampler
read-only
easeInOut Sampler
read-only
easeOut Sampler
read-only
linear Sampler
read-only

Enums

Ease

Typedefs

RetryWhenStreamFactory(dynamic error, StackTrace stack) → Stream<void>
Sampler(double startValue, double changeInTime, int currentTimeMs int durationMs) → double
StreamFactory<T>() → Stream<T>

Exceptions / Errors

RetryError