rx_streams library
Classes
-
AmbStream<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. [...]
-
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. [...]
-
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. [...]
-
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. [...]
-
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. [...]
Typedefs
-
Sampler(double startValue, double changeInTime, int currentTimeMs, int durationMs)
→ double
-
