| Package | Description |
|---|---|
| rx.internal.operators |
Operators that allow composing Observables to transform and manipulate data in an asynchronous, functional and thread-safe manner.
|
| rx.subjects |
| Class and Description |
|---|
| Subject
Represents an object that is both an Observable and an Observer.
|
| Class and Description |
|---|
| AsyncSubject
Subject that publishes only the last item observed to each
Observer that has subscribed, when the source
Observable completes.
|
| BehaviorSubject
Subject that emits the most recent item it has observed and all subsequent observed items to each subscribed
Observer.
|
| PublishSubject
Subject that, once an
Observer has subscribed, emits all subsequently observed items to the subscriber.
|
| ReplaySubject
Subject that buffers all items it observes and replays them to any
Observer that subscribes.
|
| SerializedSubject
Wraps a
Subject so that it is safe to call its various
on methods from different threads.
|
| Subject
Represents an object that is both an Observable and an Observer.
|
| TestSubject
A variety of Subject that is useful for testing purposes.
|