Package rx.subjects
package rx.subjects
Classes extending the Observable base reactive class and implementing
the Observer interface at the same time (aka hot Observables).
-
ClassDescriptionAsyncSubject<T>Subject that publishes only the last item observed to each
Observer
once the sourceObservable
has completed.Subject that emits the most recent item it has observed and all subsequent observed items to each subscribedObserver
.Subject that, once anObserver
has subscribed, emits all subsequently observed items to the subscriber.Subject that buffers all items it observes and replays them to anyObserver
that subscribes.The base interface for buffering signals to be replayed to individual Subscribers.A producer and subscription implementation that tracks the current replay position of a particular subscriber.Holds onto the array of Subscriber-wrapping ReplayProducers and the buffer that holds values to be replayed; it manages subscription and signal dispatching.An unbounded ReplayBuffer implementation that uses linked-arrays to avoid copy-on-grow situation with ArrayList.SerializedSubject<T,R> Wraps aSubject
so that it is safe to call its variouson
methods from different threads.Subject<T,R> Represents an object that is both an Observable and an Observer.Represents the typical state and OnSubscribe logic for a Subject implementation.State-machine representing the termination state and active SubjectObservers.Observer wrapping the actual Subscriber and providing various emission facilities.TestSubject<T>A variety of Subject that is useful for testing purposes.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.The single-consumption replaying state.