Package rx.subjects
Classes extending the Observable base reactive class and implementing
the Observer interface at the same time (aka hot Observables).
-
Interface Summary Interface Description ReplaySubject.ReplayBuffer<T> The base interface for buffering signals to be replayed to individual Subscribers. -
Class Summary Class Description AsyncSubject<T> Subject that publishes only the last item observed to eachObserver
once the sourceObservable
has completed.BehaviorSubject<T> Subject that emits the most recent item it has observed and all subsequent observed items to each subscribedObserver
.PublishSubject<T> Subject that, once anObserver
has subscribed, emits all subsequently observed items to the subscriber.ReplaySubject<T> Subject that buffers all items it observes and replays them to anyObserver
that subscribes.ReplaySubject.ReplayProducer<T> A producer and subscription implementation that tracks the current replay position of a particular subscriber.ReplaySubject.ReplaySizeAndTimeBoundBuffer<T> ReplaySubject.ReplaySizeAndTimeBoundBuffer.TimedNode<T> ReplaySubject.ReplaySizeBoundBuffer<T> ReplaySubject.ReplaySizeBoundBuffer.Node<T> ReplaySubject.ReplayState<T> Holds onto the array of Subscriber-wrapping ReplayProducers and the buffer that holds values to be replayed; it manages subscription and signal dispatching.ReplaySubject.ReplayUnboundedBuffer<T> 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.SubjectSubscriptionManager<T> Represents the typical state and OnSubscribe logic for a Subject implementation.SubjectSubscriptionManager.State<T> State-machine representing the termination state and active SubjectObservers.SubjectSubscriptionManager.SubjectObserver<T> Observer wrapping the actual Subscriber and providing various emission facilities.TestSubject<T> A variety of Subject that is useful for testing purposes.UnicastSubject<T> 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<T> The single-consumption replaying state.