| AsyncSubject |
Subject that publishes only the last item observed to each Observer once the source Observable
has completed. |
| 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. |
| ReplaySubject.ReplayBuffer |
The base interface for buffering signals to be replayed to individual
Subscribers.
|
| ReplaySubject.ReplayProducer |
A producer and subscription implementation that tracks the current
replay position of a particular subscriber.
|
| ReplaySubject.ReplaySizeAndTimeBoundBuffer.TimedNode |
|
| ReplaySubject.ReplaySizeBoundBuffer.Node |
|
| ReplaySubject.ReplayState |
Holds onto the array of Subscriber-wrapping ReplayProducers and
the buffer that holds values to be replayed; it manages
subscription and signal dispatching.
|
| 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.
|
| SubjectSubscriptionManager |
Represents the typical state and OnSubscribe logic for a Subject implementation.
|
| SubjectSubscriptionManager.State |
State-machine representing the termination state and active SubjectObservers.
|
| SubjectSubscriptionManager.SubjectObserver |
Observer wrapping the actual Subscriber and providing various
emission facilities.
|
| TestSubject |
A variety of Subject that is useful for testing purposes.
|
| 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.
|
| UnicastSubject.State |
The single-consumption replaying state.
|