Uses of Class
rx.Subscriber

Packages that use Subscriber

Package	Description
rx	Base reactive classes: Observable, Single and Completable; base reactive consumers; other common base interfaces.
rx.internal.operators	Operators that allow composing Observables to transform and manipulate data in an asynchronous, functional and thread-safe manner.
rx.internal.producers
rx.internal.util
rx.observables	Classes extending the Observable base reactive class, synchronous and asynchronous event generators.
rx.observers	Default wrappers and implementations for the base reactive consumer classes and interfaces; utility classes for creating them from callbacks.
rx.subjects	Classes extending the Observable base reactive class and implementing the Observer interface at the same time (aka hot Observables).

Uses of Subscriber in rx

Fields in rx declared as Subscriber

Modifier and Type	Field	Description
private final Subscriber<?>	Subscriber.subscriber

Methods in rx with parameters of type Subscriber

Modifier and Type	Method	Description
void	Observable.OnSubscribeExtend.call(Subscriber<? super T> subscriber)
final <T> void	Completable.subscribe(Subscriber<T> s)	Subscribes a regular Subscriber to this Completable instance which will receive only an onError or onComplete event and handles exceptions thrown by its onXXX methods.
final Subscription	Observable.subscribe(Subscriber<? super T> subscriber)	Subscribes to an Observable and provides a Subscriber that implements functions to handle the items the Observable emits and any error or completion notification it issues.
(package private) static <T> Subscription	Observable.subscribe(Subscriber<? super T> subscriber, Observable<T> observable)
final Subscription	Single.subscribe(Subscriber<? super T> subscriber)	Subscribes to a Single and provides a Subscriber that implements functions to handle the item the Single emits or any error notification it issues.
final <T> void	Completable.unsafeSubscribe(Subscriber<T> s)	Subscribes a regular Subscriber to this Completable instance which will receive only an onError or onComplete event.
private final <T> void	Completable.unsafeSubscribe(Subscriber<T> s, boolean callOnStart)	Performs the actual unsafe subscription and calls the onStart if required.
final Subscription	Observable.unsafeSubscribe(Subscriber<? super T> subscriber)	Subscribes to an Observable and invokes Observable.OnSubscribe function without any contract protection, error handling, unsubscribe, or execution hooks.
final Subscription	Single.unsafeSubscribe(Subscriber<? super T> subscriber)	Subscribes to a Single and invokes the Single.OnSubscribe function without any contract protection, error handling, unsubscribe, or execution hooks.

Constructors in rx with parameters of type Subscriber

Modifier	Constructor	Description
protected	Subscriber(Subscriber<?> subscriber)	Construct a Subscriber by using another Subscriber for backpressure and for holding the subscription list (when this.add(sub) is called this will in fact call subscriber.add(sub)).
protected	Subscriber(Subscriber<?> subscriber, boolean shareSubscriptions)	Construct a Subscriber by using another Subscriber for backpressure and optionally for holding the subscription list (if shareSubscriptions is true then when this.add(sub) is called this will in fact call subscriber.add(sub)).

Uses of Subscriber in rx.internal.operators

Subclasses of Subscriber in rx.internal.operators

Modifier and Type	Class	Description
(package private) static final class	BlockingOperatorLatest.LatestObserverIterator<T>	Observer of source, iterator for output.
(package private) static final class	BlockingOperatorMostRecent.MostRecentObserver<T>
(package private) static final class	BlockingOperatorNext.NextObserver<T>
static final class	BlockingOperatorToIterator.SubscriberIterator<T>
(package private) static final class	CompletableOnSubscribeConcat.CompletableConcatSubscriber
(package private) static final class	CompletableOnSubscribeMerge.CompletableMergeSubscriber
class	DeferredScalarSubscriber<T,R>	Base class for Subscribers that consume the entire upstream and signal zero or one element (or an error) in a backpressure honoring fashion.
(package private) static final class	OnSubscribeAmb.AmbSubscriber<T>
(package private) static final class	OnSubscribeCollect.CollectSubscriber<T,R>
(package private) static final class	OnSubscribeCombineLatest.CombinerSubscriber<T,R>
(package private) static final class	OnSubscribeConcatMap.ConcatMapInnerSubscriber<T,R>
(package private) static final class	OnSubscribeConcatMap.ConcatMapSubscriber<T,R>
(package private) static final class	OnSubscribeDetach.DetachSubscriber<T>	The parent subscriber that forwards events and cleans up on a terminal state.
(package private) static final class	OnSubscribeFilter.FilterSubscriber<T>
(package private) static final class	OnSubscribeFlattenIterable.FlattenIterableSubscriber<T,R>
(package private) final class	OnSubscribeGroupJoin.ResultManager.LeftDurationObserver	Observe left duration and apply termination.
(package private) final class	OnSubscribeGroupJoin.ResultManager.LeftObserver	Observe the left source.
(package private) final class	OnSubscribeGroupJoin.ResultManager.RightDurationObserver	Observe right duration and apply termination.
(package private) final class	OnSubscribeGroupJoin.ResultManager.RightObserver	Observe the right source.
(package private) final class	OnSubscribeGroupJoin.WindowObservableFunc.WindowSubscriber	Observe activities on the window.
(package private) final class	OnSubscribeJoin.ResultSink.LeftSubscriber	Observes the left values.
(package private) final class	OnSubscribeJoin.ResultSink.LeftSubscriber.LeftDurationSubscriber	Observes the left duration.
(package private) final class	OnSubscribeJoin.ResultSink.RightSubscriber	Observes the right values.
(package private) final class	OnSubscribeJoin.ResultSink.RightSubscriber.RightDurationSubscriber	Observe the right duration.
(package private) static final class	OnSubscribeMap.MapSubscriber<T,R>
(package private) static final class	OnSubscribeOnAssembly.OnAssemblySubscriber<T>
(package private) static final class	OnSubscribePublishMulticast.ParentSubscriber<T>	The subscriber that must be used for subscribing to the upstream source.
(package private) static final class	OnSubscribeReduce.ReduceSubscriber<T>
(package private) static final class	OnSubscribeReduceSeed.ReduceSeedSubscriber<T,R>
(package private) static final class	OnSubscribeTakeLastOne.TakeLastOneSubscriber<T>
(package private) final class	OperatorBufferWithSingleObservable.BufferingSubscriber
(package private) static final class	OperatorBufferWithSize.BufferExact<T>
(package private) static final class	OperatorBufferWithSize.BufferOverlap<T>
(package private) static final class	OperatorBufferWithSize.BufferSkip<T>
(package private) final class	OperatorBufferWithStartEndObservable.BufferingSubscriber
(package private) final class	OperatorBufferWithTime.ExactSubscriber	Subscriber when exact timed chunking is required.
(package private) final class	OperatorBufferWithTime.InexactSubscriber	Subscriber when the buffer chunking time and length differ.
(package private) static final class	OperatorCast.CastSubscriber<T,R>
(package private) static final class	OperatorDoOnRequest.ParentSubscriber<T>
(package private) static final class	OperatorEagerConcatMap.EagerInnerSubscriber<T>
(package private) static final class	OperatorEagerConcatMap.EagerOuterSubscriber<T,R>
static final class	OperatorGroupBy.GroupBySubscriber<T,K,V>
(package private) static final class	OperatorMapNotification.MapNotificationSubscriber<T,R>
(package private) static final class	OperatorMapPair.MapPairSubscriber<T,U,R>
(package private) static class	OperatorMaterialize.ParentSubscriber<T>
(package private) static final class	OperatorMerge.InnerSubscriber<T>
(package private) static final class	OperatorMerge.MergeSubscriber<T>	The subscriber that observes Observables.
(package private) static final class	OperatorObserveOn.ObserveOnSubscriber<T>	Observe through individual queue per observer.
(package private) static final class	OperatorOnBackpressureBuffer.BufferSubscriber<T>
(package private) static final class	OperatorOnBackpressureLatest.LatestSubscriber<T>
(package private) static final class	OperatorPublish.PublishSubscriber<T>
(package private) static final class	OperatorReplay.ReplaySubscriber<T>
(package private) static final class	OperatorRetryWithPredicate.SourceSubscriber<T>
(package private) static final class	OperatorSampleWithTime.SamplerSubscriber<T>	The source subscriber and sampler.
(package private) static final class	OperatorSingle.ParentSubscriber<T>
(package private) static final class	OperatorSwitch.InnerSubscriber<T>
(package private) static final class	OperatorSwitch.SwitchSubscriber<T>
(package private) static final class	OperatorSwitchIfEmpty.AlternateSubscriber<T>
(package private) static final class	OperatorSwitchIfEmpty.ParentSubscriber<T>
(package private) static final class	OperatorTakeLast.TakeLastSubscriber<T>
(package private) static final class	OperatorTakeLastTimed.TakeLastTimedSubscriber<T>
(package private) static final class	OperatorTakeTimed.TakeSubscriber<T>	Subscribed to source and scheduled on a worker.
(package private) final class	OperatorTakeUntilPredicate.ParentSubscriber	Subscriber returned to the upstream.
(package private) static final class	OperatorTimeoutBase.TimeoutSubscriber<T>
(package private) static final class	OperatorWindowWithObservable.BoundarySubscriber<T,U>	Observes the boundary.
(package private) static final class	OperatorWindowWithObservable.SourceSubscriber<T>	Observes the source.
(package private) static final class	OperatorWindowWithObservableFactory.BoundarySubscriber<T,U>	Observes the boundary.
(package private) static final class	OperatorWindowWithObservableFactory.SourceSubscriber<T,U>	Observes the source.
(package private) static final class	OperatorWindowWithSize.WindowExact<T>
(package private) static final class	OperatorWindowWithSize.WindowOverlap<T>
(package private) static final class	OperatorWindowWithSize.WindowSkip<T>
(package private) final class	OperatorWindowWithStartEndObservable.SourceSubscriber
(package private) final class	OperatorWindowWithTime.ExactSubscriber	Subscriber with exact, non-overlapping windows.
(package private) final class	OperatorWindowWithTime.InexactSubscriber	Subscriber with inexact, potentially overlapping or discontinuous windows.
(package private) static final class	OperatorWithLatestFromMany.WithLatestMainSubscriber<T,R>
(package private) static final class	OperatorWithLatestFromMany.WithLatestOtherSubscriber
(package private) final class	OperatorZip.Zip.InnerSubscriber
(package private) final class	OperatorZip.ZipSubscriber

Fields in rx.internal.operators declared as Subscriber

Modifier and Type	Field	Description
protected final Subscriber<? super R>	DeferredScalarSubscriber.actual	The downstream subscriber.
(package private) final Subscriber<? super R>	OnSubscribeCombineLatest.LatestCoordinator.actual
(package private) final Subscriber<? super R>	OnSubscribeConcatMap.ConcatMapSubscriber.actual
(package private) final Subscriber<? super T>	OnSubscribeFilter.FilterSubscriber.actual
(package private) final Subscriber<? super R>	OnSubscribeFlattenIterable.FlattenIterableSubscriber.actual
(package private) final Subscriber<? super T>	OnSubscribeFromAsync.BaseAsyncEmitter.actual
(package private) final Subscriber<? super R>	OnSubscribeMap.MapSubscriber.actual
(package private) final Subscriber<? super T>	OnSubscribeOnAssembly.OnAssemblySubscriber.actual
(package private) final Subscriber<? super T>	OnSubscribePublishMulticast.PublishProducer.actual	The actual subscriber to receive the events.
(package private) final Subscriber<? super T>	OnSubscribeReduce.ReduceSubscriber.actual
(package private) final Subscriber<? super List<T>>	OperatorBufferWithSize.BufferExact.actual
(package private) final Subscriber<? super List<T>>	OperatorBufferWithSize.BufferOverlap.actual
(package private) final Subscriber<? super List<T>>	OperatorBufferWithSize.BufferSkip.actual
(package private) final Subscriber<? super R>	OperatorCast.CastSubscriber.actual
(package private) final Subscriber<? super R>	OperatorEagerConcatMap.EagerOuterSubscriber.actual
(package private) final Subscriber<? super GroupedObservable<K,V>>	OperatorGroupBy.GroupBySubscriber.actual
(package private) final Subscriber<? super R>	OperatorMapNotification.MapNotificationSubscriber.actual
(package private) final Subscriber<? super Observable<? extends R>>	OperatorMapPair.MapPairSubscriber.actual
(package private) final Subscriber<? super T>	OperatorTakeLast.TakeLastSubscriber.actual
(package private) final Subscriber<? super T>	OperatorTakeLastTimed.TakeLastTimedSubscriber.actual
(package private) final Subscriber<? super Observable<T>>	OperatorWindowWithSize.WindowExact.actual
(package private) final Subscriber<? super Observable<T>>	OperatorWindowWithSize.WindowOverlap.actual
(package private) final Subscriber<? super Observable<T>>	OperatorWindowWithSize.WindowSkip.actual
(package private) final Subscriber<? super R>	OperatorWithLatestFromMany.WithLatestMainSubscriber.actual
(package private) final Subscriber<? super T>	CachedObservable.ReplayProducer.child	The actual child subscriber.
(package private) final Subscriber<? super T>	OnSubscribeFromArray.FromArrayProducer.child
(package private) final Subscriber<? super List<T>>	OperatorBufferWithSingleObservable.BufferingSubscriber.child
(package private) final Subscriber<? super List<T>>	OperatorBufferWithStartEndObservable.BufferingSubscriber.child
(package private) final Subscriber<? super List<T>>	OperatorBufferWithTime.ExactSubscriber.child
(package private) final Subscriber<? super List<T>>	OperatorBufferWithTime.InexactSubscriber.child
private final Subscriber<? super T>	OperatorDoOnRequest.ParentSubscriber.child
private final Subscriber<? super Notification<T>>	OperatorMaterialize.ParentSubscriber.child
(package private) final Subscriber<? super T>	OperatorMerge.MergeSubscriber.child
(package private) final Subscriber<? super T>	OperatorObserveOn.ObserveOnSubscriber.child
private final Subscriber<? super T>	OperatorOnBackpressureBuffer.BufferSubscriber.child
(package private) final Subscriber<? super T>	OperatorOnBackpressureLatest.LatestEmitter.child
(package private) final Subscriber<? super T>	OperatorPublish.InnerProducer.child	The actual child subscriber.
(package private) Subscriber<? super T>	OperatorReplay.InnerProducer.child	The actual child subscriber.
(package private) final Subscriber<? super T>	OperatorRetryWithPredicate.SourceSubscriber.child
(package private) final Subscriber<? super R>	OperatorScan.InitialProducer.child
private final Subscriber<? super T>	OperatorSingle.ParentSubscriber.child
(package private) final Subscriber<? super T>	OperatorSwitch.SwitchSubscriber.child
private final Subscriber<? super T>	OperatorSwitchIfEmpty.AlternateSubscriber.child
private final Subscriber<? super T>	OperatorSwitchIfEmpty.ParentSubscriber.child
(package private) final Subscriber<? super T>	OperatorTakeTimed.TakeSubscriber.child
private final Subscriber<? super T>	OperatorTakeUntilPredicate.ParentSubscriber.child
(package private) final Subscriber<? super Observable<T>>	OperatorWindowWithObservable.SourceSubscriber.child
(package private) final Subscriber<? super Observable<T>>	OperatorWindowWithObservableFactory.SourceSubscriber.child
(package private) final Subscriber<? super Observable<T>>	OperatorWindowWithStartEndObservable.SourceSubscriber.child
(package private) final Subscriber<? super Observable<T>>	OperatorWindowWithTime.ExactSubscriber.child
(package private) final Subscriber<? super Observable<T>>	OperatorWindowWithTime.InexactSubscriber.child
(package private) final Subscriber<? super R>	OperatorZip.ZipSubscriber.child
private final Subscriber<? super Integer>	OnSubscribeRange.RangeProducer.childSubscriber
private final Subscriber<? super T>	OnSubscribeFromIterable.IterableProducer.o
private final Subscriber<? super T>	OnSubscribeAmb.AmbSubscriber.subscriber
(package private) final Subscriber<? super R>	OnSubscribeGroupJoin.ResultManager.subscriber
(package private) final Subscriber<? super T>	OnSubscribeGroupJoin.WindowObservableFunc.WindowSubscriber.subscriber
(package private) final Subscriber<? super R>	OnSubscribeJoin.ResultSink.subscriber
private final Subscriber<? super T>	OperatorSampleWithTime.SamplerSubscriber.subscriber
(package private) Subscriber<T>	OperatorMulticast.subscription	Guarded by guard.

Fields in rx.internal.operators with type parameters of type Subscriber

Modifier and Type	Field	Description
(package private) final AtomicReference<Subscriber<? super T>>	OnSubscribeDetach.DetachSubscriber.actual
(package private) final AtomicReference<Subscriber<? super T>>	OperatorGroupBy.State.actual
(package private) final List<Subscriber<? super R>>	OperatorMulticast.waitingForConnect

Methods in rx.internal.operators that return Subscriber

Modifier and Type	Method	Description
Subscriber<? super T>	OperatorAll.call(Subscriber<? super Boolean> child)
Subscriber<? super T>	OperatorAny.call(Subscriber<? super Boolean> child)
Subscriber<? super T>	OperatorAsObservable.call(Subscriber<? super T> s)
Subscriber<? super T>	OperatorBufferWithSingleObservable.call(Subscriber<? super List<T>> child)
Subscriber<? super T>	OperatorBufferWithSize.call(Subscriber<? super List<T>> child)
Subscriber<? super T>	OperatorBufferWithStartEndObservable.call(Subscriber<? super List<T>> child)
Subscriber<? super T>	OperatorBufferWithTime.call(Subscriber<? super List<T>> child)
Subscriber<? super T>	OperatorCast.call(Subscriber<? super R> o)
Subscriber<? super T>	OperatorDebounceWithSelector.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorDebounceWithTime.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorDelay.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorDelayWithSelector.call(Subscriber<? super T> _child)
Subscriber<? super Notification<T>>	OperatorDematerialize.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorDistinct.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorDistinctUntilChanged.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorDoAfterTerminate.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorDoOnEach.call(Subscriber<? super T> observer)
Subscriber<? super T>	OperatorDoOnRequest.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorDoOnSubscribe.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorDoOnUnsubscribe.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorEagerConcatMap.call(Subscriber<? super R> t)
Subscriber<? super T>	OperatorElementAt.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorGroupBy.call(Subscriber<? super GroupedObservable<K,V>> child)
Subscriber<? super T>	OperatorIgnoreElements.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorMapNotification.call(Subscriber<? super R> child)
Subscriber<? super T>	OperatorMapPair.call(Subscriber<? super Observable<? extends R>> o)
Subscriber<? super T>	OperatorMaterialize.call(Subscriber<? super Notification<T>> child)
Subscriber<Observable<? extends T>>	OperatorMerge.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorObserveOn.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorOnBackpressureBuffer.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorOnBackpressureDrop.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorOnBackpressureLatest.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorOnErrorResumeNextViaFunction.call(Subscriber<? super T> child)
Subscriber<? super Observable<T>>	OperatorRetryWithPredicate.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorSampleWithObservable.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorSampleWithTime.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorScan.call(Subscriber<? super R> child)
Subscriber<? super T>	OperatorSerialize.call(Subscriber<? super T> s)
Subscriber<? super T>	OperatorSingle.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorSkip.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorSkipLast.call(Subscriber<? super T> subscriber)
Subscriber<? super T>	OperatorSkipLastTimed.call(Subscriber<? super T> subscriber)
Subscriber<? super T>	OperatorSkipTimed.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorSkipUntil.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorSkipWhile.call(Subscriber<? super T> child)
Subscriber<? super Observable<? extends T>>	OperatorSwitch.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorSwitchIfEmpty.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorTake.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorTakeLast.call(Subscriber<? super T> subscriber)
Subscriber<? super T>	OperatorTakeLastTimed.call(Subscriber<? super T> subscriber)
Subscriber<? super T>	OperatorTakeTimed.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorTakeUntil.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorTakeUntilPredicate.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorTakeWhile.call(Subscriber<? super T> subscriber)
Subscriber<? super T>	OperatorThrottleFirst.call(Subscriber<? super T> subscriber)
Subscriber<? super T>	OperatorTimeInterval.call(Subscriber<? super TimeInterval<T>> subscriber)
Subscriber<? super T>	OperatorTimeoutBase.call(Subscriber<? super T> subscriber)
Subscriber<? super T>	OperatorTimestamp.call(Subscriber<? super Timestamped<T>> o)
Subscriber<? super T>	OperatorToMap.call(Subscriber<? super Map<K,V>> subscriber)
Subscriber<? super T>	OperatorToMultimap.call(Subscriber<? super Map<K,Collection<V>>> subscriber)
Subscriber<? super T>	OperatorToObservableList.call(Subscriber<? super List<T>> o)
Subscriber<? super T>	OperatorToObservableSortedList.call(Subscriber<? super List<T>> child)
Subscriber<? super T>	OperatorUnsubscribeOn.call(Subscriber<? super T> subscriber)
Subscriber<? super T>	OperatorWindowWithObservable.call(Subscriber<? super Observable<T>> child)
Subscriber<? super T>	OperatorWindowWithObservableFactory.call(Subscriber<? super Observable<T>> child)
Subscriber<? super T>	OperatorWindowWithSize.call(Subscriber<? super Observable<T>> child)
Subscriber<? super T>	OperatorWindowWithStartEndObservable.call(Subscriber<? super Observable<T>> child)
Subscriber<? super T>	OperatorWindowWithTime.call(Subscriber<? super Observable<T>> child)
Subscriber<? super T>	OperatorWithLatestFrom.call(Subscriber<? super R> child)
Subscriber<? super Observable[]>	OperatorZip.call(Subscriber<? super R> child)
Subscriber<? super T1>	OperatorZipIterable.call(Subscriber<? super R> subscriber)
Subscriber<T>	OnSubscribePublishMulticast.subscriber()	Returns the input subscriber of this class that must be subscribed to the upstream source.

Methods in rx.internal.operators with parameters of type Subscriber

Modifier and Type	Method	Description
void	BufferUntilSubscriber.OnSubscribeAction.call(Subscriber<? super T> s)
void	CachedObservable.CachedSubscribe.call(Subscriber<? super T> t)
void	EmptyObservableHolder.call(Subscriber<? super Object> child)
void	NeverObservableHolder.call(Subscriber<? super Object> child)
void	OnSubscribeAmb.call(Subscriber<? super T> subscriber)
void	OnSubscribeAutoConnect.call(Subscriber<? super T> child)
void	OnSubscribeCollect.call(Subscriber<? super R> t)
void	OnSubscribeCombineLatest.call(Subscriber<? super R> s)
void	OnSubscribeConcatMap.call(Subscriber<? super R> child)
void	OnSubscribeDefer.call(Subscriber<? super T> s)
void	OnSubscribeDelaySubscription.call(Subscriber<? super T> s)
void	OnSubscribeDelaySubscriptionOther.call(Subscriber<? super T> t)
void	OnSubscribeDelaySubscriptionWithSelector.call(Subscriber<? super T> child)
void	OnSubscribeDetach.call(Subscriber<? super T> t)
void	OnSubscribeFilter.call(Subscriber<? super T> child)
void	OnSubscribeFlattenIterable.call(Subscriber<? super R> t)
void	OnSubscribeFlattenIterable.OnSubscribeScalarFlattenIterable.call(Subscriber<? super R> t)
void	OnSubscribeFromArray.call(Subscriber<? super T> child)
void	OnSubscribeFromAsync.call(Subscriber<? super T> t)
void	OnSubscribeFromCallable.call(Subscriber<? super T> subscriber)
void	OnSubscribeFromIterable.call(Subscriber<? super T> o)
void	OnSubscribeGroupJoin.call(Subscriber<? super R> child)
void	OnSubscribeGroupJoin.WindowObservableFunc.call(Subscriber<? super T> t1)
void	OnSubscribeJoin.call(Subscriber<? super R> t1)
void	OnSubscribeLift.call(Subscriber<? super R> o)
void	OnSubscribeMap.call(Subscriber<? super R> o)
void	OnSubscribeOnAssembly.call(Subscriber<? super T> t)
void	OnSubscribePublishMulticast.call(Subscriber<? super T> t)
void	OnSubscribeRange.call(Subscriber<? super Integer> childSubscriber)
void	OnSubscribeRedo.call(Subscriber<? super T> child)
void	OnSubscribeReduce.call(Subscriber<? super T> t)
void	OnSubscribeReduceSeed.call(Subscriber<? super R> t)
void	OnSubscribeRefCount.call(Subscriber<? super T> subscriber)
void	OnSubscribeTakeLastOne.call(Subscriber<? super T> t)
void	OnSubscribeThrow.call(Subscriber<? super T> observer)	Accepts an Observer and calls its onError method.
void	OnSubscribeTimerOnce.call(Subscriber<? super Long> child)
void	OnSubscribeTimerPeriodically.call(Subscriber<? super Long> child)
void	OnSubscribeToObservableFuture.ToObservableFuture.call(Subscriber<? super T> subscriber)
void	OnSubscribeUsing.call(Subscriber<? super T> subscriber)
Subscriber<? super T>	OperatorAll.call(Subscriber<? super Boolean> child)
Subscriber<? super T>	OperatorAny.call(Subscriber<? super Boolean> child)
Subscriber<? super T>	OperatorAsObservable.call(Subscriber<? super T> s)
Subscriber<? super T>	OperatorBufferWithSingleObservable.call(Subscriber<? super List<T>> child)
Subscriber<? super T>	OperatorBufferWithSize.call(Subscriber<? super List<T>> child)
Subscriber<? super T>	OperatorBufferWithStartEndObservable.call(Subscriber<? super List<T>> child)
Subscriber<? super T>	OperatorBufferWithTime.call(Subscriber<? super List<T>> child)
Subscriber<? super T>	OperatorCast.call(Subscriber<? super R> o)
Subscriber<? super T>	OperatorDebounceWithSelector.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorDebounceWithTime.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorDelay.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorDelayWithSelector.call(Subscriber<? super T> _child)
Subscriber<? super Notification<T>>	OperatorDematerialize.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorDistinct.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorDistinctUntilChanged.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorDoAfterTerminate.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorDoOnEach.call(Subscriber<? super T> observer)
Subscriber<? super T>	OperatorDoOnRequest.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorDoOnSubscribe.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorDoOnUnsubscribe.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorEagerConcatMap.call(Subscriber<? super R> t)
Subscriber<? super T>	OperatorElementAt.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorGroupBy.call(Subscriber<? super GroupedObservable<K,V>> child)
void	OperatorGroupBy.State.call(Subscriber<? super T> s)
Subscriber<? super T>	OperatorIgnoreElements.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorMapNotification.call(Subscriber<? super R> child)
Subscriber<? super T>	OperatorMapPair.call(Subscriber<? super Observable<? extends R>> o)
Subscriber<? super T>	OperatorMaterialize.call(Subscriber<? super Notification<T>> child)
Subscriber<Observable<? extends T>>	OperatorMerge.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorObserveOn.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorOnBackpressureBuffer.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorOnBackpressureDrop.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorOnBackpressureLatest.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorOnErrorResumeNextViaFunction.call(Subscriber<? super T> child)
Subscriber<? super Observable<T>>	OperatorRetryWithPredicate.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorSampleWithObservable.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorSampleWithTime.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorScan.call(Subscriber<? super R> child)
Subscriber<? super T>	OperatorSerialize.call(Subscriber<? super T> s)
Subscriber<? super T>	OperatorSingle.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorSkip.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorSkipLast.call(Subscriber<? super T> subscriber)
Subscriber<? super T>	OperatorSkipLastTimed.call(Subscriber<? super T> subscriber)
Subscriber<? super T>	OperatorSkipTimed.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorSkipUntil.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorSkipWhile.call(Subscriber<? super T> child)
void	OperatorSubscribeOn.call(Subscriber<? super T> subscriber)
Subscriber<? super Observable<? extends T>>	OperatorSwitch.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorSwitchIfEmpty.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorTake.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorTakeLast.call(Subscriber<? super T> subscriber)
Subscriber<? super T>	OperatorTakeLastTimed.call(Subscriber<? super T> subscriber)
Subscriber<? super T>	OperatorTakeTimed.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorTakeUntil.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorTakeUntilPredicate.call(Subscriber<? super T> child)
Subscriber<? super T>	OperatorTakeWhile.call(Subscriber<? super T> subscriber)
Subscriber<? super T>	OperatorThrottleFirst.call(Subscriber<? super T> subscriber)
Subscriber<? super T>	OperatorTimeInterval.call(Subscriber<? super TimeInterval<T>> subscriber)
Subscriber<? super T>	OperatorTimeoutBase.call(Subscriber<? super T> subscriber)
Subscriber<? super T>	OperatorTimestamp.call(Subscriber<? super Timestamped<T>> o)
Subscriber<? super T>	OperatorToMap.call(Subscriber<? super Map<K,V>> subscriber)
Subscriber<? super T>	OperatorToMultimap.call(Subscriber<? super Map<K,Collection<V>>> subscriber)
Subscriber<? super T>	OperatorToObservableList.call(Subscriber<? super List<T>> o)
Subscriber<? super T>	OperatorToObservableSortedList.call(Subscriber<? super List<T>> child)
Subscriber<? super T>	OperatorUnsubscribeOn.call(Subscriber<? super T> subscriber)
Subscriber<? super T>	OperatorWindowWithObservable.call(Subscriber<? super Observable<T>> child)
Subscriber<? super T>	OperatorWindowWithObservableFactory.call(Subscriber<? super Observable<T>> child)
Subscriber<? super T>	OperatorWindowWithSize.call(Subscriber<? super Observable<T>> child)
Subscriber<? super T>	OperatorWindowWithStartEndObservable.call(Subscriber<? super Observable<T>> child)
Subscriber<? super T>	OperatorWindowWithTime.call(Subscriber<? super Observable<T>> child)
Subscriber<? super T>	OperatorWithLatestFrom.call(Subscriber<? super R> child)
void	OperatorWithLatestFromMany.call(Subscriber<? super R> t)
Subscriber<? super Observable[]>	OperatorZip.call(Subscriber<? super R> child)
Subscriber<? super T1>	OperatorZipIterable.call(Subscriber<? super R> subscriber)
(package private) boolean	OnSubscribeCombineLatest.LatestCoordinator.checkTerminated(boolean mainDone, boolean queueEmpty, Subscriber<?> childSubscriber, Queue<?> q, boolean delayError)
(package private) boolean	OnSubscribeFlattenIterable.FlattenIterableSubscriber.checkTerminated(boolean d, boolean empty, Subscriber<?> a, Queue<?> q)
(package private) boolean	OperatorGroupBy.GroupBySubscriber.checkTerminated(boolean d, boolean empty, Subscriber<? super GroupedObservable<K,V>> a, Queue<?> q)
(package private) boolean	OperatorGroupBy.State.checkTerminated(boolean d, boolean empty, Subscriber<? super T> a, boolean delayError)
(package private) boolean	OperatorObserveOn.ObserveOnSubscriber.checkTerminated(boolean done, boolean isEmpty, Subscriber<? super T> a, Queue<Object> q)
(package private) boolean	OperatorScan.InitialProducer.checkTerminated(boolean d, boolean empty, Subscriber<? super R> child)
protected boolean	OperatorSwitch.SwitchSubscriber.checkTerminated(boolean localMainDone, boolean localInnerActive, Throwable localError, SpscLinkedArrayQueue<Object> localQueue, Subscriber<? super T> localChild, boolean empty)
(package private) boolean	OperatorWindowWithSize.WindowOverlap.checkTerminated(boolean d, boolean empty, Subscriber<? super Subject<T,T>> a, Queue<Subject<T,T>> q)
(package private) void	OnSubscribeRefCount.doSubscribe(Subscriber<? super T> subscriber, CompositeSubscription currentBase)
void	OperatorDebounceWithTime.DebounceState.emit(int index, Subscriber<T> onNextAndComplete, Subscriber<?> onError)
void	OperatorDebounceWithTime.DebounceState.emitAndComplete(Subscriber<T> onNextAndComplete, Subscriber<?> onError)
(package private) void	OperatorGroupBy.GroupBySubscriber.errorAll(Subscriber<? super GroupedObservable<K,V>> a, Queue<?> q, Throwable ex)
private Action1<Subscription>	OnSubscribeRefCount.onSubscribe(Subscriber<? super T> subscriber, AtomicBoolean writeLocked)
static <T, R> void	BackpressureUtils.postCompleteDone(AtomicLong requested, Queue<T> queue, Subscriber<? super R> actual, Func1<? super T,? extends R> exitTransform)	Signals the completion of the main sequence and switches to post-completion replay mode and allows exit transformation on the queued values.
static <T> void	BackpressureUtils.postCompleteDone(AtomicLong requested, Queue<T> queue, Subscriber<? super T> actual)	Signals the completion of the main sequence and switches to post-completion replay mode.
(package private) static <T, R> void	BackpressureUtils.postCompleteDrain(AtomicLong requested, Queue<T> queue, Subscriber<? super R> subscriber, Func1<? super T,? extends R> exitTransform)	Drains the queue based on the outstanding requests in post-completed mode (only!) and allows exit transformation on the queued values.
static <T, R> boolean	BackpressureUtils.postCompleteRequest(AtomicLong requested, long n, Queue<T> queue, Subscriber<? super R> actual, Func1<? super T,? extends R> exitTransform)	Accumulates requests (validated) and handles the completed mode draining of the queue based on the requests and allows exit transformation on the queued values.
static <T> boolean	BackpressureUtils.postCompleteRequest(AtomicLong requested, long n, Queue<T> queue, Subscriber<? super T> actual)	Accumulates requests (validated) and handles the completed mode draining of the queue based on the requests.

Constructors in rx.internal.operators with parameters of type Subscriber

Modifier	Constructor	Description
(package private)	AlternateSubscriber(Subscriber<? super T> child, ProducerArbiter arbiter)
(package private)	AmbSubscriber(long requested, Subscriber<? super T> subscriber, OnSubscribeAmb.Selection<T> selection)
	BaseAsyncEmitter(Subscriber<? super T> actual)
	BufferAsyncEmitter(Subscriber<? super T> actual, int capacityHint)
	BufferExact(Subscriber<? super List<T>> actual, int count)
	BufferingSubscriber(Subscriber<? super List<T>> child)
	BufferingSubscriber(Subscriber<? super List<T>> child)
	BufferOverlap(Subscriber<? super List<T>> actual, int count, int skip)
	BufferSkip(Subscriber<? super List<T>> actual, int count, int skip)
	BufferSubscriber(Subscriber<? super T> child, Long capacity, Action0 onOverflow, BackpressureOverflow.Strategy overflowStrategy)
	CastSubscriber(Subscriber<? super R> actual, Class<R> castClass)
	CollectSubscriber(Subscriber<? super R> actual, R initialValue, Action2<R,? super T> collector)
	ConcatMapSubscriber(Subscriber<? super R> actual, Func1<? super T,? extends Observable<? extends R>> mapper, int prefetch, int delayErrorMode)
	DeferredScalarSubscriber(Subscriber<? super R> actual)
	DetachSubscriber(Subscriber<? super T> actual)
	DropAsyncEmitter(Subscriber<? super T> actual)
	EagerOuterSubscriber(Func1<? super T,? extends Observable<? extends R>> mapper, int bufferSize, int maxConcurrent, Subscriber<? super R> actual)
	ErrorAsyncEmitter(Subscriber<? super T> actual)
	ExactSubscriber(Subscriber<? super List<T>> child, Scheduler.Worker inner)
	ExactSubscriber(Subscriber<? super Observable<T>> child, Scheduler.Worker worker)
	FilterSubscriber(Subscriber<? super T> actual, Func1<? super T,Boolean> predicate)
	FlattenIterableSubscriber(Subscriber<? super R> actual, Func1<? super T,? extends Iterable<? extends R>> mapper, int prefetch)
	FromArrayProducer(Subscriber<? super T> child, T[] array)
	GroupBySubscriber(Subscriber<? super GroupedObservable<K,V>> actual, Func1<? super T,? extends K> keySelector, Func1<? super T,? extends V> valueSelector, int bufferSize, boolean delayError, Func1<Action1<K>,Map<K,Object>> mapFactory)
	InexactSubscriber(Subscriber<? super List<T>> child, Scheduler.Worker inner)
	InexactSubscriber(Subscriber<? super Observable<T>> child, Scheduler.Worker worker)
	InitialProducer(R initialValue, Subscriber<? super R> child)
	InnerProducer(OperatorPublish.PublishSubscriber<T> parent, Subscriber<? super T> child)
	InnerProducer(OperatorReplay.ReplaySubscriber<T> parent, Subscriber<? super T> child)
(package private)	IterableProducer(Subscriber<? super T> o, Iterator<? extends T> it)
	LatestAsyncEmitter(Subscriber<? super T> actual)
	LatestCoordinator(Subscriber<? super R> actual, FuncN<? extends R> combiner, int count, int bufferSize, boolean delayError)
	LatestEmitter(Subscriber<? super T> child)
	MapNotificationSubscriber(Subscriber<? super R> actual, Func1<? super T,? extends R> onNext, Func1<? super Throwable,? extends R> onError, Func0<? extends R> onCompleted)
	MapPairSubscriber(Subscriber<? super Observable<? extends R>> actual, Func1<? super T,? extends Observable<? extends U>> collectionSelector, Func2<? super T,? super U,? extends R> resultSelector)
	MapSubscriber(Subscriber<? super R> actual, Func1<? super T,? extends R> mapper)
	MergeSubscriber(Subscriber<? super T> child, boolean delayErrors, int maxConcurrent)
	NoneAsyncEmitter(Subscriber<? super T> actual)
	NoOverflowBaseAsyncEmitter(Subscriber<? super T> actual)
	ObserveOnSubscriber(Scheduler scheduler, Subscriber<? super T> child, boolean delayError, int bufferSize)
	OnAssemblySubscriber(Subscriber<? super T> actual, String stacktrace)
(package private)	ParentSubscriber(Subscriber<? super T> child)
(package private)	ParentSubscriber(Subscriber<? super Notification<T>> child)
(package private)	ParentSubscriber(Subscriber<? super T> child, boolean hasDefaultValue, T defaultValue)
(package private)	ParentSubscriber(Subscriber<? super T> child, SerialSubscription ssub, ProducerArbiter arbiter, Observable<? extends T> alternate)
(package private)	ParentSubscriber(Subscriber<? super T> child)
	PublishProducer(Subscriber<? super T> actual, OnSubscribePublishMulticast<T> parent)
(package private)	RangeProducer(Subscriber<? super Integer> childSubscriber, int startIndex, int endIndex)
	ReduceSeedSubscriber(Subscriber<? super R> actual, R initialValue, Func2<R,? super T,R> reducer)
	ReduceSubscriber(Subscriber<? super T> actual, Func2<T,T,T> reducer)
	ReplayProducer(Subscriber<? super T> child, CachedObservable.CacheState<T> state)
	ResultManager(Subscriber<? super R> subscriber)
	ResultSink(Subscriber<? super R> subscriber)
	SamplerSubscriber(Subscriber<? super T> subscriber)
	SourceSubscriber(Subscriber<? super T> child, Func2<Integer,Throwable,Boolean> predicate, Scheduler.Worker inner, SerialSubscription serialSubscription, ProducerArbiter pa)
	SourceSubscriber(Subscriber<? super Observable<T>> child)
	SourceSubscriber(Subscriber<? super Observable<T>> child, Func0<? extends Observable<? extends U>> otherFactory)
	SourceSubscriber(Subscriber<? super Observable<T>> child, CompositeSubscription csub)
(package private)	SwitchSubscriber(Subscriber<? super T> child, boolean delayError)
	TakeLastOneSubscriber(Subscriber<? super T> actual)
	TakeLastSubscriber(Subscriber<? super T> actual, int count)
	TakeLastTimedSubscriber(Subscriber<? super T> actual, int count, long ageMillis, Scheduler scheduler)
	TakeSubscriber(Subscriber<? super T> child)
	WindowExact(Subscriber<? super Observable<T>> actual, int size)
	WindowOverlap(Subscriber<? super Observable<T>> actual, int size, int skip)
	WindowSkip(Subscriber<? super Observable<T>> actual, int size, int skip)
	WindowSubscriber(Subscriber<? super T> subscriber, Subscription ref)
	WithLatestMainSubscriber(Subscriber<? super R> actual, FuncN<R> combiner, int n)
	Zip(Subscriber<? super R> child, FuncN<? extends R> zipFunction)
	ZipSubscriber(Subscriber<? super R> child, OperatorZip.Zip<R> zipper, OperatorZip.ZipProducer<R> producer)

Constructor parameters in rx.internal.operators with type arguments of type Subscriber

Modifier	Constructor	Description
private	OperatorMulticast(Object guard, AtomicReference<Subject<? super T,? extends R>> connectedSubject, List<Subscriber<? super R>> waitingForConnect, Observable<? extends T> source, Func0<? extends Subject<? super T,? extends R>> subjectFactory)

Uses of Subscriber in rx.internal.producers

Fields in rx.internal.producers declared as Subscriber

Modifier and Type	Field	Description
(package private) final Subscriber<? super T>	ProducerObserverArbiter.child
(package private) final Subscriber<? super T>	QueuedProducer.child
(package private) final Subscriber<? super T>	QueuedValueProducer.child
(package private) final Subscriber<? super T>	SingleDelayedProducer.child	The child to emit the value and completion once possible.
(package private) final Subscriber<? super T>	SingleProducer.child	The child subscriber.

Methods in rx.internal.producers with parameters of type Subscriber

Modifier and Type	Method	Description
private static <T> void	SingleDelayedProducer.emit(Subscriber<? super T> c, T v)	Emits the given value to the child subscriber and completes it and checks for unsubscriptions eagerly.

Constructors in rx.internal.producers with parameters of type Subscriber

Modifier	Constructor	Description
	ProducerObserverArbiter(Subscriber<? super T> child)
	QueuedProducer(Subscriber<? super T> child)	Constructs an instance with the target child subscriber and an Spsc Linked (Atomic) Queue as the queue implementation.
	QueuedProducer(Subscriber<? super T> child, Queue<Object> queue)	Constructs an instance with the target child subscriber and a custom queue implementation
	QueuedValueProducer(Subscriber<? super T> child)	Constructs an instance with the target child subscriber and an Spsc Linked (Atomic) Queue as the queue implementation.
	QueuedValueProducer(Subscriber<? super T> child, Queue<Object> queue)	Constructs an instance with the target child subscriber and a custom queue implementation
	SingleDelayedProducer(Subscriber<? super T> child)	Constructor, wraps the target child subscriber.
	SingleProducer(Subscriber<? super T> child, T value)	Constructs the producer with the given target child and value to be emitted.

Uses of Subscriber in rx.internal.util

Subclasses of Subscriber in rx.internal.util

Modifier and Type	Class	Description
final class	ActionSubscriber<T>	A Subscriber that forwards the onXXX method calls to callbacks.
final class	ObserverSubscriber<T>	Wraps an Observer and forwards the onXXX method calls to it.

Fields in rx.internal.util declared as Subscriber

Modifier and Type	Field	Description
(package private) final Subscriber<? super T>	ScalarSynchronousObservable.ScalarAsyncProducer.actual
(package private) final Subscriber<? super T>	ScalarSynchronousObservable.WeakSingleProducer.actual

Methods in rx.internal.util with parameters of type Subscriber

Modifier and Type	Method	Description
void	ScalarSynchronousObservable.JustOnSubscribe.call(Subscriber<? super T> s)
void	ScalarSynchronousObservable.ScalarAsyncOnSubscribe.call(Subscriber<? super T> s)
(package private) static <T> Producer	ScalarSynchronousObservable.createProducer(Subscriber<? super T> s, T v)	Creates a scalar producer depending on the state of STRONG_MODE.

Constructors in rx.internal.util with parameters of type Subscriber

Modifier	Constructor	Description
	ScalarAsyncProducer(Subscriber<? super T> actual, T value, Func1<Action0,Subscription> onSchedule)
	WeakSingleProducer(Subscriber<? super T> actual, T value)

Uses of Subscriber in rx.observables

Fields in rx.observables declared as Subscriber

Modifier and Type	Field	Description
private final Subscriber<? super T>	SyncOnSubscribe.SubscriptionProducer.actualSubscriber
(package private) Subscriber<? super T>	AsyncOnSubscribe.UnicastSubject.State.subscriber

Methods in rx.observables with parameters of type Subscriber

Modifier and Type	Method	Description
final void	AsyncOnSubscribe.call(Subscriber<? super T> actualSubscriber)
void	AsyncOnSubscribe.UnicastSubject.State.call(Subscriber<? super T> s)
final void	SyncOnSubscribe.call(Subscriber<? super T> subscriber)
private void	SyncOnSubscribe.SubscriptionProducer.handleThrownError(Subscriber<? super T> a, Throwable ex)
void	BlockingObservable.subscribe(Subscriber<? super T> subscriber)	Subscribes to the source and calls the Subscriber methods on the current thread.

Constructors in rx.observables with parameters of type Subscriber

Modifier	Constructor	Description
(package private)	SubscriptionProducer(Subscriber<? super T> subscriber, SyncOnSubscribe<S,T> parent, S state)

Uses of Subscriber in rx.observers

Subclasses of Subscriber in rx.observers

Modifier and Type	Class	Description
class	SafeSubscriber<T>	SafeSubscriber is a wrapper around Subscriber that ensures that the Subscriber complies with the Observable contract.
class	SerializedSubscriber<T>	Enforces single-threaded, serialized, ordered execution of SerializedSubscriber.onNext(T), SerializedSubscriber.onCompleted(), and SerializedSubscriber.onError(java.lang.Throwable).
class	TestSubscriber<T>	A TestSubscriber is a variety of Subscriber that you can use for unit testing, to perform assertions, inspect received events, or wrap a mocked Subscriber.

Fields in rx.observers declared as Subscriber

Modifier and Type	Field	Description
private final Subscriber<? super T>	SafeSubscriber.actual

Methods in rx.observers that return Subscriber

Modifier and Type	Method	Description
static <T> Subscriber<T>	Subscribers.create(Action1<? super T> onNext)	Creates a Subscriber that receives the emissions of any Observable it subscribes to via onNext but ignores onCompleted notifications; it will throw an OnErrorNotImplementedException if onError is invoked.
static <T> Subscriber<T>	Subscribers.create(Action1<? super T> onNext, Action1<Throwable> onError)	Creates an Subscriber that receives the emissions of any Observable it subscribes to via onNext and handles any onError notification but ignores an onCompleted notification.
static <T> Subscriber<T>	Subscribers.create(Action1<? super T> onNext, Action1<Throwable> onError, Action0 onComplete)	Creates an Subscriber that receives the emissions of any Observable it subscribes to via onNext and handles any onError or onCompleted notifications.
static <T> Subscriber<T>	Subscribers.empty()	Returns an inert Subscriber that does nothing in response to the emissions or notifications from any Observable it subscribes to.
static <T> Subscriber<T>	Subscribers.from(Observer<? super T> o)	Converts an Observer into a Subscriber.
Subscriber<? super T>	SafeSubscriber.getActual()	Returns the Subscriber underlying this SafeSubscriber.
static <T> Subscriber<T>	Subscribers.wrap(Subscriber<? super T> subscriber)	Returns a new Subscriber that passes all events to subscriber, has backpressure controlled by subscriber and uses the subscription list of subscriber when add(rx.Subscription) is called.

Methods in rx.observers with parameters of type Subscriber

Modifier and Type	Method	Description
static <T> TestSubscriber<T>	TestSubscriber.create(Subscriber<T> delegate)	Factory method to construct a TestSubscriber which delegates events to the given Subscriber and an issues an initial request of Long.MAX_VALUE.
static <T> Subscriber<T>	Subscribers.wrap(Subscriber<? super T> subscriber)	Returns a new Subscriber that passes all events to subscriber, has backpressure controlled by subscriber and uses the subscription list of subscriber when add(rx.Subscription) is called.

Constructors in rx.observers with parameters of type Subscriber

Modifier	Constructor	Description
	SafeSubscriber(Subscriber<? super T> actual)
	SerializedSubscriber(Subscriber<? super T> s)
	SerializedSubscriber(Subscriber<? super T> s, boolean shareSubscriptions)	Constructor for wrapping and serializing a subscriber optionally sharing the same underlying subscription list.
	TestSubscriber(Subscriber<T> delegate)	Constructs a TestSubscriber which requests Long.MAX_VALUE and delegates events to the given Subscriber.

Uses of Subscriber in rx.subjects

Fields in rx.subjects declared as Subscriber

Modifier and Type	Field	Description
(package private) final Subscriber<? super T>	ReplaySubject.ReplayProducer.actual	The wrapped Subscriber instance.
(package private) final Subscriber<? super T>	SubjectSubscriptionManager.SubjectObserver.actual	The actual Observer.

Fields in rx.subjects with type parameters of type Subscriber

Modifier and Type	Field	Description
(package private) final AtomicReference<Subscriber<? super T>>	UnicastSubject.State.subscriber	The single subscriber.

Methods in rx.subjects with parameters of type Subscriber

Modifier and Type	Method	Description
(package private) void	SubjectSubscriptionManager.addUnsubscriber(Subscriber<? super T> child, SubjectSubscriptionManager.SubjectObserver<T> bo)	Registers the unsubscribe action for the given subscriber.
void	ReplaySubject.ReplayState.call(Subscriber<? super T> t)
void	SubjectSubscriptionManager.call(Subscriber<? super T> child)
void	UnicastSubject.State.call(Subscriber<? super T> subscriber)	Tries to set the given subscriber if not already set, sending an IllegalStateException to the subscriber otherwise.
(package private) boolean	UnicastSubject.State.checkTerminated(boolean done, boolean empty, Subscriber<? super T> s)	Checks if one of the terminal conditions have been met: child unsubscribed, an error happened or the source terminated and the queue is empty

Constructors in rx.subjects with parameters of type Subscriber

Modifier	Constructor	Description
	ReplayProducer(Subscriber<? super T> actual, ReplaySubject.ReplayState<T> state)
	SubjectObserver(Subscriber<? super T> actual)