rx_transformers library

Classes

BufferCountStreamTransformer<T>
Buffers a number of values from the source Stream by count then emits the buffer and clears it, and starts a new buffer each startBufferEvery values. If startBufferEvery is not provided, then new buffers are started immediately at the start of the source and when each buffer closes and is emitted. [...]
BufferStreamTransformer<T>
Creates a Stream where each item is a List containing the items from the source sequence. [...]
BufferTestStreamTransformer<T>
Creates a Stream where each item is a List containing the items from the source sequence, batched whenever test passes. [...]
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. [...]
DefaultIfEmptyStreamTransformer<T>
Emit items from the source Stream, or a single default item if the source Stream emits nothing. [...]
DelayStreamTransformer<T>
The Delay operator modifies its source Stream by pausing for a particular increment of time (that you specify) before emitting each of the source Stream’s items. This has the effect of shifting the entire sequence of items emitted by the Stream 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 a Stream 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. [...]
ExhaustMapStreamTransformer<T, S>
Converts events 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. [...]
FlatMapStreamTransformer<T, S>
Converts each emitted item into a new Stream using the given mapper function. The newly created Stream will be listened to and begin emitting items downstream. [...]
GroupByStream<T, S>
The Stream used by GroupByStreamTransformer, it contains events that are grouped by a key value.
GroupByStreamTransformer<T, S>
The GroupBy operator divides a Stream that emits items into a Stream that emits GroupByStream, each one of which emits some subset of the items from the original source Stream. [...]
IgnoreElementsStreamTransformer<T>
Creates a Stream 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. [...]
MapToStreamTransformer<S, T>
Emits the given constant value on the output Stream every time the source Stream emits a value. [...]
MaterializeStreamTransformer<T>
Converts the onData, on Done, and onError events into Notification objects that are passed into the downstream onData listener. [...]
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.
OnErrorResumeStreamTransformer<T>
Intercepts error events and switches to a recovery stream created by the provided recoveryFn Function. [...]
PairwiseStreamTransformer<T>
Emits the n-th and n-1th events as a pair.. [...]
SampleStreamTransformer<T>
A StreamTransformer that, when the specified window 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 stream sequence and returns each intermediate result. The optional seed value is used as the initial accumulator value. [...]
SkipUntilStreamTransformer<T, S>
Starts emitting events only after the given stream emits an event. [...]
StartWithManyStreamTransformer<T>
Prepends a sequence of values to the source Stream. [...]
StartWithStreamTransformer<T>
Prepends a value to the source Stream. [...]
SwitchIfEmptyStreamTransformer<T>
When the original stream emits no items, this operator subscribes to the given fallback stream and emits items from that stream instead. [...]
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 stream sequence until the other stream sequence produces a value. [...]
ThrottleStreamTransformer<T>
A StreamTransformer that emits only the first item emitted by the source Stream while the window Stream is open. [...]
TimeInterval<T>
A class that represents a snapshot of the current value emitted by a Stream, at a specified interval.
TimeIntervalStreamTransformer<T>
Records the time interval between consecutive values in an stream sequence. [...]
Timestamped<T>
A class that represents a snapshot of the current value emitted by a Stream, at a specified timestamp.
TimestampStreamTransformer<T>
Wraps each item emitted by the source Stream in a Timestamped object that includes the emitted item and the time when the item was emitted. [...]
WhereTypeStreamTransformer<S, T>
This transformer is a shorthand for Stream.where followed by Stream.cast. [...]
WindowCountStreamTransformer<T>
Buffers a number of values from the source Stream by count then emits the buffer as a Stream and clears it, and starts a new buffer each startBufferEvery values. If startBufferEvery is not provided, then new buffers are started immediately at the start of the source and when each buffer closes and is emitted. [...]
WindowStreamTransformer<T>
Creates a Stream where each item is a Stream containing the items from the source sequence. [...]
WindowTestStreamTransformer<T>
Creates a Stream where each item is a Stream containing the items from the source sequence, batched whenever test passes. [...]
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. [...]

Extensions

BufferExtensions
Extends the Stream class with the ability to buffer events in various ways
DebounceExtensions
Extends the Stream class with the ability to debounce events in various ways
DefaultIfEmptyExtension
DelayExtension
Extends the Stream class with the ability to delay events being emitted
DematerializeExtension
Converts the onData, onDone, and onError Notifications from a materialized stream into normal onData, onDone, and onError events.
DistinctUniqueExtension
Extends the Stream class with the ability to skip items that have previously been emitted.
DoExtensions
Extends the Stream class with the ability to execute a callback function at different points in the Stream's lifecycle.
ExhaustMapExtension
Extends the Stream class with the ability to transform the Stream into a new Stream. The new Stream emits items and ignores events from the source Stream until the new Stream completes.
FlatMapExtension
Extends the Stream class with the ability to convert the source Stream into a new Stream each time the source emits an item.
GroupByExtension
Extends the Stream class with the ability to convert events into Streams of events that are united by a key.
IgnoreElementsExtension
Extends the Stream class with the ability to skip, or ignore, data events.
IntervalExtension
Extends the Stream class with the ability to emit each item after a given duration.
MapToExtension
Extends the Stream class with the ability to convert each item to the same value.
MaterializeExtension
Extends the Stream class with the ability to convert the onData, on Done, and onError events into Notifications that are passed into the downstream onData listener.
MaxExtension
Extends the Stream class with the ability to transform into a Future that completes with the largest item emitted by the Stream.
MinExtension
Extends the Stream class with the ability to transform into a Future that completes with the smallest item emitted by the Stream.
OnErrorExtensions
Extends the Stream class with the ability to recover from errors in various ways
PairwiseExtension
Extends the Stream class with the ability to emit the nth and n-1th events as a pair
SampleExtensions
Extends the Stream class with the ability to sample events from the Stream
ScanExtension
Extends
SkipUntilExtension
Extends the Stream class with the ability to skip events until another Stream emits an item.
StartWithExtension
Extends the Stream class with the ability to emit the given value as the first item.
StartWithManyExtension
Extends the Stream class with the ability to emit the given values as the first items.
SwitchIfEmptyExtension
Extend the Stream class with the ability to return an alternative Stream if the initial Stream completes with no items.
SwitchMapExtension
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.
TakeUntilExtension
Extends the Stream class with the ability receive events from the source Stream until another Stream produces a value.
ThrottleExtensions
Extends the Stream class with the ability to throttle events in various ways
TimeIntervalExtension
Extends the Stream class with the ability to record the time interval between consecutive values in an stream
TimeStampExtension
Extends the Stream class with the ability to wrap each item emitted by the source Stream in a Timestamped object that includes the emitted item and the time when the item was emitted.
WhereTypeExtension
Extends the Stream class with the ability to filter down events to only those of a specific type.
WindowExtensions
Extends the Stream class with the ability to window
WithLatestFromExtensions
Extends the Stream class with the ability to merge the source Stream with the last emitted item from another Stream.

Enums

Kind
The type of event used in Notification