re_listener_modifiers
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<S>
-
Emit items from the source Stream, or a single default item if the source
Stream emits nothing.
-
DelayStreamTransformer<S>
-
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.
-
DelayWhenStreamTransformer<T>
-
Delays the emission of items from the source Stream by a given time span
determined by the emissions of another Stream.
-
DematerializeStreamTransformer<S>
-
Converts the onData, onDone, and onError
Notification objects from a
materialized stream into normal onData, onDone, and onError events.
-
DistinctUniqueStreamTransformer<S>
-
Create a Stream which implements a HashSet under the hood, using
the provided
equals as equality.
-
DoStreamTransformer<S>
-
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.
-
EndWithManyStreamTransformer<S>
-
Appends a sequence of values to the source Stream.
-
EndWithStreamTransformer<S>
-
Appends a value to the source Stream before closing.
-
ExhaustMapStreamTransformer<S, T>
-
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<S, T>
-
Converts each emitted item into a new Stream using the given mapper function,
while limiting the maximum number of concurrent subscriptions to these Streams.
The newly created Stream will be listened to and begin emitting items downstream.
-
GroupByStreamTransformer<T, K>
-
The GroupBy operator divides a Stream that emits items into
a Stream that emits GroupedStream,
each one of which emits some subset of the items
from the original source Stream.
-
GroupedStream<T, K>
-
The Stream used by GroupByStreamTransformer, it contains events
that are grouped by a key value.
-
IgnoreElementsStreamTransformer<S>
-
Creates a Stream where all emitted items are ignored, only the
error / completed notifications are passed
-
IntervalStreamTransformer<S>
-
Creates a Stream that emits each item in the Stream after a given
duration.
-
MapNotNullStreamTransformer<T, R extends Object>
-
Create a Stream containing only the non-
null results
of applying the given transform function to each element of the Stream.
-
MapToStreamTransformer<S, T>
-
Emits the given constant value on the output Stream every time the source
Stream emits a value.
-
MaterializeStreamTransformer<S>
-
Converts the onData, on Done, and onError events into
Notification
objects that are passed into the downstream onData listener.
-
OnErrorResumeStreamTransformer<S>
-
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.
The first event won't be emitted until the second one arrives.
-
ReListenerModifiers
-
A collection of static methods that return ReListenerModifier functions.
These functions can be used to modify the behavior of a
ReListenerModifier.
-
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<S, T>
-
Applies an accumulator function over an stream sequence and returns
each intermediate result. The seed value is used as the initial
accumulator value.
-
SkipLastStreamTransformer<T>
-
Skip the last count items emitted by the source Stream
-
SkipUntilStreamTransformer<S, T>
-
Starts emitting events only after the given stream emits an event.
-
StartWithManyStreamTransformer<S>
-
Prepends a sequence of values to the source Stream.
-
StartWithStreamTransformer<S>
-
Prepends a value to the source Stream.
-
SwitchIfEmptyStreamTransformer<S>
-
When the original stream emits no items, this operator subscribes to
the given fallback stream and emits items from that stream instead.
-
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.
-
TakeLastStreamTransformer<T>
-
Emits only the final count values emitted by the source Stream.
-
TakeUntilStreamTransformer<S, T>
-
Returns the values from the source stream sequence until the other
stream sequence produces a value.
-
TakeWhileInclusiveStreamTransformer<S>
-
Emits values emitted by the source Stream so long as each value
satisfies the given test. When the test is not satisfied by a value, it
will emit this value as a final event and then complete.
-
ThrottleStreamTransformer<T>
-
A StreamTransformer that emits a value from the source Stream,
then ignores subsequent source values while the window Stream is open,
then repeats this process.
-
TimeInterval<T>
-
A class that represents a snapshot of the current value emitted by a
Stream, at a specified interval.
-
TimeIntervalStreamTransformer<S>
-
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<S>
-
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.
-
WhereNotNullStreamTransformer<T extends Object>
-
Create a Stream which emits all the non-
null elements of the Stream,
in their original emission order.
-
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<S, T, R>
-
A StreamTransformer that emits when the source stream emits, combining
the latest values from the two streams using the provided function.
Extensions
-
BufferExtensions
on Stream<T>
-
Extends the Stream class with the ability to buffer events in various ways
-
DebounceExtensions
on Stream<T>
-
Extends the Stream class with the ability to debounce events in various ways
-
DefaultIfEmptyExtension
on Stream<T>
-
-
DelayExtension
on Stream<T>
-
Extends the Stream class with the ability to delay events being emitted
-
DelayWhenExtension
on Stream<T>
-
Extends the Stream class with the ability to delay events being emitted.
-
DematerializeExtension
on Stream<Notification<T>>
-
Converts the onData, onDone, and onError
Notifications from a
materialized stream into normal onData, onDone, and onError events.
-
DistinctUniqueExtension
on Stream<T>
-
Extends the Stream class with the ability to skip items that have previously
been emitted.
-
DoExtensions
on Stream<T>
-
Extends the Stream class with the ability to execute a callback function
at different points in the Stream's lifecycle.
-
EndWithExtension
on Stream<T>
-
Extends the Stream class with the ability to emit the given value as the
final item before closing.
-
EndWithManyExtension
on Stream<T>
-
Extends the Stream class with the ability to emit the given value as the
final item before closing.
-
ExhaustMapExtension
on Stream<T>
-
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
on Stream<T>
-
Extends the Stream class with the ability to convert the source Stream into
a new Stream each time the source emits an item.
-
GroupByExtension
on Stream<T>
-
Extends the Stream class with the ability to convert events into Streams
of events that are united by a key.
-
IgnoreElementsExtension
on Stream<T>
-
Extends the Stream class with the ability to skip, or ignore, data events.
-
IntervalExtension
on Stream<T>
-
Extends the Stream class with the ability to emit each item after a given
duration.
-
MapNotNullExtension
on Stream<T>
-
Extends the Stream class with the ability to convert the source Stream
to a Stream containing only the non-
null results
of applying the given transform function to each element of this Stream.
-
MapToExtension
on Stream<S>
-
Extends the Stream class with the ability to convert each item to the same
value.
-
MaterializeExtension
on Stream<T>
-
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
on Stream<T>
-
Extends the Stream class with the ability to transform into a Future
that completes with the largest item emitted by the Stream.
-
MinExtension
on Stream<T>
-
Extends the Stream class with the ability to transform into a Future
that completes with the smallest item emitted by the Stream.
-
OnErrorExtensions
on Stream<T>
-
Extends the Stream class with the ability to recover from errors in various
ways
-
PairwiseExtension
on Stream<T>
-
Extends the Stream class with the ability to emit the nth and n-1th events
as a pair
-
SampleExtensions
on Stream<T>
-
Extends the Stream class with the ability to sample events from the Stream
-
ScanExtension
on Stream<T>
-
Extends
-
SkipLastExtension
on Stream<T>
-
Extends the Stream class with the ability to skip the last
count items
emitted by the source Stream
-
SkipUntilExtension
on Stream<T>
-
Extends the Stream class with the ability to skip events until another
Stream emits an item.
-
StartWithExtension
on Stream<T>
-
Extends the Stream class with the ability to emit the given value as the
first item.
-
StartWithManyExtension
on Stream<T>
-
Extends the Stream class with the ability to emit the given values as the
first items.
-
SwitchIfEmptyExtension
on Stream<T>
-
Extend the Stream class with the ability to return an alternative Stream
if the initial Stream completes with no items.
-
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.
-
TakeLastExtension
on Stream<T>
-
Extends the Stream class with the ability receive only the final
count
events from the source Stream.
-
TakeUntilExtension
on Stream<T>
-
Extends the Stream class with the ability receive events from the source
Stream until another Stream produces a value.
-
TakeWhileInclusiveExtension
on Stream<T>
-
Extends the Stream class with the ability to take events while they pass
the condition given and include last event that doesn't pass the condition.
-
ThrottleExtensions
on Stream<T>
-
Extends the Stream class with the ability to throttle events in various ways
-
TimeIntervalExtension
on Stream<T>
-
Extends the Stream class with the ability to record the time interval
between consecutive values in an stream
-
TimeStampExtension
on Stream<T>
-
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.
-
WhereNotNullExtension
on Stream<T?>
-
Extends the Stream class with the ability to convert the source Stream
to a Stream which emits all the non-
null elements
of this Stream, in their original emission order.
-
WhereTypeExtension
on Stream<T>
-
Extends the Stream class with the ability to filter down events to only
those of a specific type.
-
WindowExtensions
on Stream<T>
-
Extends the Stream class with the ability to window
-
WithLatestFromExtensions
on Stream<T>
-
Extends the Stream class with the ability to merge the source Stream with
the last emitted item from another Stream.
