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
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
DebounceStreamTransformer < T>
Stream so that will only emit items from the source sequence
if a window has completed, without the source sequence emitting
DeferStream < T>
The defer factory waits until a listener subscribes to it, and then it
creates a Stream with the given factory function.
An Object which acts as a tuple containing both an error and the
corresponding stack trace.
ForwardingSink < T, R>
Sink that supports event hooks.
MergeStream < T>
Flattens the items emitted by the given streams into a single Stream
A utility class that provides static methods to create the various Streams
provided by RxDart.
StartWithErrorStreamTransformer < S>
Prepends an error to the source
StartWithStreamTransformer < S>
Prepends a value to the source
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>
Stream that provides synchronous access to the last emitted item
ValueWrapper < T>
Wrap a value.
This used to keep the latest value of a
Extends the Stream class with the ability to debounce events in various ways
Extends the Stream class with the ability to merge one stream with another.
Stream class with the ability to emit the given value as the
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.
Extensions to access value and error easily.