| 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.
|
| 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.
|
| OperatorMerge
Flattens a list of
Observables into one
Observable, without any transformation.
|