rx library

Classes

AmbStream<T>
Deprecated: Use RaceStream [...]
AsObservableFuture<T>
A future that can be converted directly to an Observable using the asObservable method. [...]
BehaviorSubject<T>
A special StreamController that captures the latest item that has been added to the controller, and emits that as the first item to any new listener. [...]
BufferStreamTransformer<T>
Creates an Observable where each item is a List containing the items from the source sequence, batched by the sampler. [...]
BufferWithCountStreamTransformer<T>
Deprecated: Use BufferCountStreamTransformer [...]
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. [...]
DebounceStreamTransformer<T>
Transforms a Stream so that will only emit items from the source sequence if a particular time span has passed without the source sequence emitting another item. [...]
DefaultIfEmptyStreamTransformer<T>
Emit items from the source Stream, or a single default item if the source Stream emits nothing. [...]
DeferStream<T>
The defer factory waits until an observer subscribes to it, and then it creates an Observable with the given factory function. [...]
DelayStreamTransformer<T>
The Delay operator modifies its source Observable by pausing for a particular increment of time (that you specify) before emitting each of the source Observable’s items. This has the effect of shifting the entire sequence of items emitted by the Observable forward in time by that specified increment. [...]
DematerializeStreamTransformer<T>
Converts the onData, onDone, and onError Notification objects from a materialized stream into normal onData, onDone, and onError events. [...]
DistinctUniqueStreamTransformer<T>
Create an Observable which implements a HashSet under the hood, using the provided equals as equality. [...]
DoStreamTransformer<T>
Invokes the given callback at the corresponding point the the stream lifecycle. For example, if you pass in an onDone callback, it will be invoked when the stream finishes emitting items. [...]
ErrorAndStacktrace
ErrorStream<T>
Returns an observable sequence that emits an error, then immediately completes. [...]
ExhaustMapStreamTransformer<T, S>
Converts items from the source stream into a new Stream using a given mapper. It ignores all items from the source stream until the new stream completes. [...]
FlatMapLatestStreamTransformer<T, S>
Deprecated: Use SwitchMapStreamTransformer. [...]
FlatMapStreamTransformer<T, S>
Converts each emitted item into a new Stream using the given mapper function. The newly created Stream will be be listened to and begin emitting items downstream. [...]
IgnoreElementsStreamTransformer<T>
Creates an Observable where all emitted items are ignored, only the error / completed notifications are passed [...]
IntervalStreamTransformer<T>
Creates a Stream that emits each item in the Stream after a given duration. [...]
MaterializeStreamTransformer<T>
Converts the onData, on Done, and onError events into Notification objects that are passed into the downstream onData listener. [...]
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. [...]
Notification<T>
A class that encapsulates the Kind of event, value of the event in case of onData, or the Error in the case of onError. A container object that wraps the Kind of event (OnData, OnDone, OnError), and the item or error that was emitted. In the case of onDone, no data is emitted as part of the Notification.
Observable<T>
A wrapper class that extends Stream. It combines all the Streams and StreamTransformers contained in this library into a fluent api. [...]
OfTypeStreamTransformer<T, S>
Filters a sequence so that only events of a given type pass [...]
OnErrorResumeNextStreamTransformer<T>
Deprecated: Please use OnErrorResumeStreamTransformer. [...]
OnErrorResumeStreamTransformer<T>
Intercepts error events and switches to a recovery stream created by the provided recoveryFn function. [...]
PublishSubject<T>
Exactly like a normal broadcast StreamController with one exception: stream returns an Observable instead of a Stream. [...]
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. [...]
RepeatStreamTransformer<T>
A StreamTransformer that repeats the source's elements the specified number of times. [...]
ReplaySubject<T>
A special StreamController that captures all of the items that have been added to the controller, and emits those as the first items to any new listener. [...]
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. [...]
SampleStreamTransformer<T>
A StreamTransformer that, when the specified sample stream emits an item or completes, emits the most recently emitted item (if any) emitted by the source stream since the previous emission from the sample stream. [...]
ScanStreamTransformer<T, S>
Applies an accumulator function over an observable sequence and returns each intermediate result. The optional seed value is used as the initial accumulator value. [...]
SkipUntilStreamTransformer<T, S>
Starts emitting items only after the given stream emits an item. [...]
StartWithManyStreamTransformer<T>
Prepends a sequence of values to the source Stream. [...]
StartWithStreamTransformer<T>
Prepends a value to the source Stream. [...]
StreamMaxFuture<T>
Converts a Stream into a Future that completes with the largest item emitted by the Stream. [...]
StreamMinFuture<T>
Converts a Stream into a Future that completes with the smallest item emitted by the Stream. [...]
Subject<T>
The base for all Subjects. If you'd like to create a new Subject, extend from this class. [...]
SwitchIfEmptyStreamTransformer<T>
When the original observable emits no items, this operator subscribes to the given fallback stream and emits items from that observable instead. [...]
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. [...]
SwitchMapStreamTransformer<T, S>
Converts each emitted item into a new 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. [...]
TakeUntilStreamTransformer<T, S>
Returns the values from the source observable sequence until the other stream sequence produces a value. [...]
ThrottleStreamTransformer<T>
A StreamTransformer that emits only the first item emitted by the source Stream during sequential time windows of a specified duration. [...]
TimeInterval<T>
TimeIntervalStreamTransformer<T>
Records the time interval between consecutive values in an observable sequence. [...]
TimerStream<T>
Emits the given value after a specified amount of time. [...]
Timestamped<T>
TimestampStreamTransformer<T>
Wraps each item emitted by the source Observable in a Timestamped object that includes the emitted item and the time when the item was emitted. [...]
TweenStream
Creates a Stream that emits values starting from startValue and incrementing according to the ease type over the duration. [...]
TypeToken<S>
A class that captures the Type to filter down to using ofType or cast. [...]
WindowStreamTransformer<T>
Creates an Observable where each item is a Stream containing the items from the source sequence, batched by the sampler. [...]
WindowWithCountStreamTransformer<T>
Deprecated: Please use WindowCountStreamTransformer. [...]
WithLatestFromStreamTransformer<T, S, R>
A StreamTransformer that emits when the source stream emits, combining the latest values from the two streams using the provided function. [...]
WrappedFuture<T>
A future that simply wraps another Future. [...]
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. [...]

Constants

kBool → const TypeToken<bool>
Filter the observable to only Booleans
const TypeToken<bool>()
kDouble → const TypeToken<double>
Filter the observable to only Doubles
const TypeToken<double>()
kInt → const TypeToken<int>
Filter the observable to only Integers
const TypeToken<int>()
kNum → const TypeToken<num>
Filter the observable to only Numbers
const TypeToken<num>()
kString → const TypeToken<String>
Filter the observable to only Strings
const TypeToken<String>()
kSymbol → const TypeToken<Symbol>
Filter the observable to only Symbols
const TypeToken<Symbol>()

Properties

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

Functions

onCount<T, S>(int count, [ int skip ]) → Stream<S> Function(Stream<T> stream, OnDataTransform<T, S> , OnDataTransform<S, S> )
Higher order function implementation for _OnCountSampler which matches the method signature of buffer and window. [...]
onFuture<T, S, O>(Future<O> onFuture()) → Stream<S> Function(Stream<T> stream, OnDataTransform<T, S> , OnDataTransform<S, S> )
Higher order function implementation for _OnStreamSampler which matches the method signature of buffer and window. [...]
onStream<T, S, O>(Stream<O> onStream) → Stream<S> Function(Stream<T> stream, OnDataTransform<T, S> , OnDataTransform<S, S> )
Higher order function implementation for _OnStreamSampler which matches the method signature of buffer and window. [...]
onTest<T, S>(bool onTest(T event)) → Stream<S> Function(Stream<T> stream, OnDataTransform<T, S> , OnDataTransform<S, S> )
Higher order function implementation for _OnTestSampler which matches the method signature of buffer and window. [...]
onTime<T, S>(Duration duration) → Stream<S> Function(Stream<T> stream, OnDataTransform<T, S> , OnDataTransform<S, S> )
Higher order function implementation for _OnStreamSampler which matches the method signature of buffer and window. [...]

Enums

Ease
Kind
The type of event

Typedefs

FutureFunc() → Future
OnDataTransform<T, S>(T event, EventSink<S> sink, [ int skip ]) → void
RetryWhenStreamFactory(dynamic error, StackTrace stack) → Stream<void>
Sampler(double startValue, double changeInTime, int currentTimeMs, int durationMs) → double
SamplerBuilder<T, S>(Stream<T> stream, OnDataTransform<T, S> bufferHandler, OnDataTransform<S, S> scheduleHandler) → Stream<S>
Higher order function signature which matches the method signature of buffer and window.
StreamFactory<T>() → Stream<T>
VoidFunc() → void

Exceptions / Errors

RetryError