Packages that use Subscriber

• Uses of Subscriber in rx

  Methods in with parameters of type

  Modifier and Type	Method and Description
  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.
  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.
  void	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.
  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.

  Constructors in rx with parameters of type Subscriber

  Constructor and Description
  	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)).
  	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 in

  Modifier and Type	Class and Description
  static class	BlockingOperatorToIterator.SubscriberIterator<T>

  Methods in that return

  Modifier and Type	Method and Description
  Subscriber<? super T>	OperatorAny.call(Subscriber<? super Boolean> child)
  Subscriber<? super T>	OperatorAll.call(Subscriber<? super Boolean> child)
  Subscriber<? super T>	OperatorGroupBy.call(Subscriber<? super GroupedObservable<K,R>> child)
  Subscriber<? super T>	OperatorToObservableList.call(Subscriber<? super List<T>> o)
  Subscriber<? super T>	OperatorToObservableSortedList.call(Subscriber<? super List<T>> child)
  Subscriber<? super T>	OperatorBufferWithSize.call(Subscriber<? super List<T>> child)
  Subscriber<? super T>	OperatorBufferWithSingleObservable.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>	OperatorToMultimap.call(Subscriber<? super Map<K,Collection<V>>> subscriber)
  Subscriber<? super T>	OperatorToMap.call(Subscriber<? super Map<K,V>> subscriber)
  Subscriber<? super T>	OperatorMaterialize.call(Subscriber<? super Notification<T>> child)
  Subscriber<? super T>	OperatorMapPair.call(Subscriber<? super Observable<? extends R>> o)
  Subscriber<? super T>	OperatorWindowWithObservableFactory.call(Subscriber<? super Observable<T>> child)
  Subscriber<? super T>	OperatorWindowWithStartEndObservable.call(Subscriber<? super Observable<T>> child)
  Subscriber<? super T>	OperatorWindowWithObservable.call(Subscriber<? super Observable<T>> child)
  Subscriber<? super T>	OperatorWindowWithTime.call(Subscriber<? super Observable<T>> child)
  Subscriber<? super T>	OperatorWindowWithSize.call(Subscriber<? super Observable<T>> child)
  Subscriber<? super T>	OperatorMap.call(Subscriber<? super R> o)
  Subscriber<? super T>	OperatorMapNotification.call(Subscriber<? super R> o)
  Subscriber<? super T>	OperatorScan.call(Subscriber<? super R> child)
  Subscriber<? super Observable[]>	OperatorZip.call(Subscriber<? super R> child)
  Subscriber<? super T>	OperatorCast.call(Subscriber<? super R> o)
  Subscriber<? super T>	OperatorEagerConcatMap.call(Subscriber<? super R> t)
  Subscriber<? super T>	OperatorWithLatestFrom.call(Subscriber<? super R> child)
  Subscriber<? super T1>	OperatorZipIterable.call(Subscriber<? super R> subscriber)
  Subscriber<? super T>	OperatorDoOnEach.call(Subscriber<? super T> observer)
  Subscriber<? super T>	OperatorOnBackpressureBuffer.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorSerialize.call(Subscriber<? super T> s)
  Subscriber<? super T>	OperatorSkipLast.call(Subscriber<? super T> subscriber)
  Subscriber<? super T>	OperatorSwitchIfEmpty.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorSingle.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorSampleWithObservable.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorDoOnRequest.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorTakeWhile.call(Subscriber<? super T> subscriber)
  Subscriber<? super T>	OperatorSkipUntil.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorSkipTimed.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorTakeLastOne.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorElementAt.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorTakeLastTimed.call(Subscriber<? super T> subscriber)
  Subscriber<? super T>	OperatorSkipLastTimed.call(Subscriber<? super T> subscriber)
  Subscriber<? super T>	OperatorTakeLast.call(Subscriber<? super T> subscriber)
  Subscriber<Observable<? extends T>>	OperatorMerge.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorOnBackpressureLatest.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorSampleWithTime.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorUnsubscribeOn.call(Subscriber<? super T> subscriber)
  Subscriber<? super T>	OperatorOnErrorResumeNextViaFunction.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorOnErrorReturn.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorTakeUntil.call(Subscriber<? super T> child)
  Subscriber<? super Observable<? extends T>>	OperatorSwitch.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorThrottleFirst.call(Subscriber<? super T> subscriber)
  Subscriber<? super T>	OperatorSkip.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorDistinct.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorTakeTimed.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorDoOnUnsubscribe.call(Subscriber<? super T> child)
  Subscriber<? super Observable<T>>	OperatorRetryWithPredicate.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorOnErrorResumeNextViaObservable.call(Subscriber<? super T> child)
  Subscriber<? super Observable<T>>	OperatorSubscribeOn.call(Subscriber<? super T> subscriber)
  Subscriber<? super T>	OperatorDelay.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorObserveOn.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorFinally.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorIgnoreElements.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorDoOnSubscribe.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorFilter.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorDistinctUntilChanged.call(Subscriber<? super T> child)
  Subscriber<? super Observable<? extends T>>	OperatorConcat.call(Subscriber<? super T> child)
  Subscriber<? super Notification<T>>	OperatorDematerialize.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorDebounceWithSelector.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorTakeUntilPredicate.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorDebounceWithTime.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorAsObservable.call(Subscriber<? super T> s)
  Subscriber<? super T>	OperatorOnBackpressureDrop.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorDelayWithSelector.call(Subscriber<? super T> _child)
  Subscriber<? super T>	OperatorTake.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorSkipWhile.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorOnExceptionResumeNextViaObservable.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorTimeInterval.call(Subscriber<? super TimeInterval<T>> subscriber)
  Subscriber<? super T>	OperatorTimestamp.call(Subscriber<? super Timestamped<T>> o)

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

  Modifier and Type	Method and Description
  Subscriber<? super T>	OperatorAny.call(Subscriber<? super Boolean> child)
  Subscriber<? super T>	OperatorAll.call(Subscriber<? super Boolean> child)
  Subscriber<? super T>	OperatorGroupBy.call(Subscriber<? super GroupedObservable<K,R>> child)
  void	OnSubscribeRange.call(Subscriber<? super Integer> o)
  Subscriber<? super T>	OperatorToObservableList.call(Subscriber<? super List<T>> o)
  Subscriber<? super T>	OperatorToObservableSortedList.call(Subscriber<? super List<T>> child)
  Subscriber<? super T>	OperatorBufferWithSize.call(Subscriber<? super List<T>> child)
  Subscriber<? super T>	OperatorBufferWithSingleObservable.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)
  void	OnSubscribeTimerOnce.call(Subscriber<? super Long> child)
  void	OnSubscribeTimerPeriodically.call(Subscriber<? super Long> child)
  Subscriber<? super T>	OperatorToMultimap.call(Subscriber<? super Map<K,Collection<V>>> subscriber)
  Subscriber<? super T>	OperatorToMap.call(Subscriber<? super Map<K,V>> subscriber)
  Subscriber<? super T>	OperatorMaterialize.call(Subscriber<? super Notification<T>> child)
  Subscriber<? super T>	OperatorMapPair.call(Subscriber<? super Observable<? extends R>> o)
  Subscriber<? super T>	OperatorWindowWithObservableFactory.call(Subscriber<? super Observable<T>> child)
  Subscriber<? super T>	OperatorWindowWithStartEndObservable.call(Subscriber<? super Observable<T>> child)
  Subscriber<? super T>	OperatorWindowWithObservable.call(Subscriber<? super Observable<T>> child)
  Subscriber<? super T>	OperatorWindowWithTime.call(Subscriber<? super Observable<T>> child)
  Subscriber<? super T>	OperatorWindowWithSize.call(Subscriber<? super Observable<T>> child)
  Subscriber<? super T>	OperatorMap.call(Subscriber<? super R> o)
  Subscriber<? super T>	OperatorMapNotification.call(Subscriber<? super R> o)
  Subscriber<? super T>	OperatorScan.call(Subscriber<? super R> child)
  void	OnSubscribeCombineLatest.call(Subscriber<? super R> child)
  Subscriber<? super Observable[]>	OperatorZip.call(Subscriber<? super R> child)
  Subscriber<? super T>	OperatorCast.call(Subscriber<? super R> o)
  void	OnSubscribeGroupJoin.call(Subscriber<? super R> child)
  Subscriber<? super T>	OperatorEagerConcatMap.call(Subscriber<? super R> t)
  void	OnSubscribeJoin.call(Subscriber<? super R> t1)
  Subscriber<? super T>	OperatorWithLatestFrom.call(Subscriber<? super R> child)
  Subscriber<? super T1>	OperatorZipIterable.call(Subscriber<? super R> subscriber)
  void	OnSubscribeDelaySubscription.call(Subscriber<? super T> s)
  Subscriber<? super T>	OperatorDoOnEach.call(Subscriber<? super T> observer)
  Subscriber<? super T>	OperatorOnBackpressureBuffer.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorSerialize.call(Subscriber<? super T> s)
  void	OnSubscribeAutoConnect.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorSkipLast.call(Subscriber<? super T> subscriber)
  Subscriber<? super T>	OperatorSwitchIfEmpty.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorSingle.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorSampleWithObservable.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorDoOnRequest.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorTakeWhile.call(Subscriber<? super T> subscriber)
  Subscriber<? super T>	OperatorSkipUntil.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorSkipTimed.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorTakeLastOne.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorElementAt.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorTakeLastTimed.call(Subscriber<? super T> subscriber)
  Subscriber<? super T>	OperatorSkipLastTimed.call(Subscriber<? super T> subscriber)
  Subscriber<? super T>	OperatorTakeLast.call(Subscriber<? super T> subscriber)
  void	OnSubscribeDelaySubscriptionWithSelector.call(Subscriber<? super T> child)
  Subscriber<Observable<? extends T>>	OperatorMerge.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorOnBackpressureLatest.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorSampleWithTime.call(Subscriber<? super T> child)
  void	OnSubscribeAmb.call(Subscriber<? super T> subscriber)
  Subscriber<? super T>	OperatorUnsubscribeOn.call(Subscriber<? super T> subscriber)
  Subscriber<? super T>	OperatorOnErrorResumeNextViaFunction.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorOnErrorReturn.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorTakeUntil.call(Subscriber<? super T> child)
  Subscriber<? super Observable<? extends T>>	OperatorSwitch.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorThrottleFirst.call(Subscriber<? super T> subscriber)
  Subscriber<? super T>	OperatorSkip.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorDistinct.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorTakeTimed.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorDoOnUnsubscribe.call(Subscriber<? super T> child)
  Subscriber<? super Observable<T>>	OperatorRetryWithPredicate.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorOnErrorResumeNextViaObservable.call(Subscriber<? super T> child)
  Subscriber<? super Observable<T>>	OperatorSubscribeOn.call(Subscriber<? super T> subscriber)
  void	OnSubscribeRefCount.call(Subscriber<? super T> subscriber)
  Subscriber<? super T>	OperatorDelay.call(Subscriber<? super T> child)
  void	OnSubscribeDefer.call(Subscriber<? super T> s)
  Subscriber<? super T>	OperatorObserveOn.call(Subscriber<? super T> child)
  void	OnSubscribeRedo.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorFinally.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorIgnoreElements.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorDoOnSubscribe.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorFilter.call(Subscriber<? super T> child)
  void	OnSubscribeFromCallable.call(Subscriber<? super T> subscriber)
  Subscriber<? super T>	OperatorDistinctUntilChanged.call(Subscriber<? super T> child)
  Subscriber<? super Observable<? extends T>>	OperatorConcat.call(Subscriber<? super T> child)
  Subscriber<? super Notification<T>>	OperatorDematerialize.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorDebounceWithSelector.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorTakeUntilPredicate.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorDebounceWithTime.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorAsObservable.call(Subscriber<? super T> s)
  Subscriber<? super T>	OperatorOnBackpressureDrop.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorDelayWithSelector.call(Subscriber<? super T> _child)
  Subscriber<? super T>	OperatorTake.call(Subscriber<? super T> child)
  void	OnSubscribeUsing.call(Subscriber<? super T> subscriber)
  void	OnSubscribeFromIterable.call(Subscriber<? super T> o)
  Subscriber<? super T>	OperatorSkipWhile.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorOnExceptionResumeNextViaObservable.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorTimeInterval.call(Subscriber<? super TimeInterval<T>> subscriber)
  Subscriber<? super T>	OperatorTimestamp.call(Subscriber<? super Timestamped<T>> o)

• Uses of Subscriber in rx.internal.producers

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

  Constructor and 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.observables

  Methods in rx.observables with parameters of type Subscriber

  Modifier and Type	Method and Description
  void	AsyncOnSubscribe.call(Subscriber<? super T> actualSubscriber)
  void	SyncOnSubscribe.call(Subscriber<? super T> subscriber)
  void	BlockingObservable.subscribe(Subscriber<? super T> subscriber) Subscribes to the source and calls the Subscriber methods on the current thread.

• Uses of Subscriber in rx.observers

  Subclasses of in

  Modifier and Type	Class and 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.

  Methods in that return

  Modifier and Type	Method and 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 onError and onCompleted notifications.
  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 with parameters of type

  Modifier and Type	Method and Description
  static <T> TestSubscriber<T>	TestSubscriber.create(Subscriber<T> delegate) Factory method to construct a TestSubscriber which delegates events to the given Observer 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

  Constructor and 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.