rxdart library

Classes

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.
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.
DebounceStreamTransformer<T>
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.
DeferStream<T>
The defer factory waits until a listener subscribes to it, and then it creates a Stream with the given factory function.
ErrorAndStackTrace
An Object which acts as a tuple containing both an error and the corresponding stack trace.
ForwardingSink<T, R>
A Sink that supports event hooks.
MergeStream<T>
Flattens the items emitted by the given streams into a single Stream sequence.
Rx
A utility class that provides static methods to create the various Streams provided by RxDart.
StartWithErrorStreamTransformer<S>
Prepends an error to the source Stream.
StartWithStreamTransformer<S>
Prepends a value to the source Stream.
Subject<T>
The base for all Subjects. If you'd like to create a new Subject, extend from this class.
SwitchMapStreamTransformer<S, T>
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.
ValueStream<T>
An Stream that provides synchronous access to the last emitted item
ValueWrapper<T>
Wrap a value. This used to keep the latest value of a Stream including null value.

Extensions

DebounceExtensions on Stream<T>
Extends the Stream class with the ability to debounce events in various ways
MergeExtension on Stream<T>
Extends the Stream class with the ability to merge one stream with another.
StartWithExtension on Stream<T>
Extends the Stream class with the ability to emit the given value as the first item.
SwitchMapExtension on Stream<T>
Extends the Stream with the ability to convert one stream into a new Stream whenever the source emits an item. Every time a new Stream is created, the previous Stream is discarded.
ValueStreamExtensions on ValueStream<T>
Extensions to access value and error easily.

Functions

forwardStream<T, R>(Stream<T> stream, ForwardingSink<T, R> connectedSink) → Stream<R>
@private Helper method which forwards the events from an incoming Stream to a new StreamController. It captures events such as onListen, onPause, onResume and onCancel, which can be used in pair with a ForwardingSink