Package rx.subjects

Class SubjectSubscriptionManager<T>

Type Parameters:
T - the source and return value type
All Implemented Interfaces:
Serializable, Action, Action1<Subscriber<? super T>>, Function, Observable.OnSubscribe<T>

final class SubjectSubscriptionManager<T> extends AtomicReference<SubjectSubscriptionManager.State<T>> implements Observable.OnSubscribe<T>
Represents the typical state and OnSubscribe logic for a Subject implementation.