| Package | Description |
|---|---|
| rx.internal.operators |
Operators that allow composing Observables to transform and manipulate data in an asynchronous, functional and thread-safe manner.
|
| Class and Description |
|---|
| BufferUntilSubscriber
A solution to the "time gap" problem that occurs with
groupBy and
pivot.
|
| CachedObservable
An observable which auto-connects to another observable, caches the elements from that observable but allows terminating the connection and completing the cache.
|
| NotificationLite
For use in internal operators that need something like materialize and dematerialize wholly within the implementation of the operator but don't want to incur the allocation cost of actually creating
Notification objects for every
onNext and
onCompleted.
|
| OnSubscribeSingle
Allows conversion of an Observable to a Single ensuring that exactly one item is emitted - no more and no less.
|
| OperatorAsObservable
Hides the identity of another observable.
|
| OperatorConcat
Returns an Observable that emits the items emitted by two or more Observables, one after the other.
|
| OperatorDematerialize
Reverses the effect of
OperatorMaterialize by transforming the Notification objects emitted by a source Observable into the items or notifications they represent.
|
| OperatorDistinct
Returns an Observable that emits all distinct items emitted by the source.
|
| OperatorDistinctUntilChanged
Returns an Observable that emits all sequentially distinct items emitted by the source.
|
| OperatorIgnoreElements |
| OperatorMaterialize
Turns all of the notifications from an Observable into
onNext emissions, and marks them with their original notification types within
Notification objects.
|
| OperatorMerge
Flattens a list of
Observables into one
Observable, without any transformation.
|
| OperatorOnBackpressureBuffer |
| OperatorOnBackpressureDrop |
| OperatorOnBackpressureLatest
An operator which drops all but the last received value in case the downstream doesn't request more.
|
| OperatorSerialize |
| OperatorSingle
If the Observable completes after emitting a single item that matches a predicate, return an Observable containing that item.
|
| OperatorSwitch
Transforms an Observable that emits Observables into a single Observable that emits the items emitted by the most recently published of those Observables.
|
| OperatorTakeLastOne |
| OperatorToObservableList
Returns an
Observable that emits a single item, a list composed of all the items emitted by the source
Observable.
|
| UnicastSubject
A Subject variant which buffers events until a single Subscriber arrives and replays them to it and potentially switches to direct delivery once the Subscriber caught up and requested an unlimited amount.
|