Packages that use Subscriber

• Uses of Subscriber in rx

  Methods in with parameters of type

  Modifier and Type	Method and Description
  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.
  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<?> op)

• Uses of Subscriber in rx.internal.operators

  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>> o)
  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>	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 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>	OperatorSingle.call(Subscriber<? super T> subscriber)
  Subscriber<? super T>	OperatorSampleWithObservable.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>	OperatorElementAt.call(Subscriber<? super T> subscriber)
  Subscriber<? super T>	OperatorTakeLastTimed.call(Subscriber<? super T> subscriber)
  Subscriber<? super T>	OperatorSkipLastTimed.call(Subscriber<? super T> subscriber)
  Subscriber<? super T>	OperatorOnErrorFlatMap.call(Subscriber<? super T> child)
  Subscriber<? super T>	OperatorTakeLast.call(Subscriber<? super T> subscriber)
  Subscriber<Observable<? extends T>>	OperatorMerge.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>	OperatorDefaultIfEmpty.call(Subscriber<? super T> child)
  Subscriber<? super Observable<? extends T>>	OperatorMergeMaxConcurrent.call(Subscriber<? super T> child)
  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>	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>	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>> o)
  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>	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)
  void	OnSubscribeJoin.call(Subscriber<? super R> t1)
  Subscriber<? super T1>	OperatorZipIterable.call(Subscriber<? super R> subscriber)
  void	OnSubscribeCache.call(Subscriber<? super T> s)
  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)
  Subscriber<? super T>	OperatorSkipLast.call(Subscriber<? super T> subscriber)
  Subscriber<? super T>	OperatorSingle.call(Subscriber<? super T> subscriber)
  Subscriber<? super T>	OperatorSampleWithObservable.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>	OperatorElementAt.call(Subscriber<? super T> subscriber)
  Subscriber<? super T>	OperatorTakeLastTimed.call(Subscriber<? super T> subscriber)
  Subscriber<? super T>	OperatorSkipLastTimed.call(Subscriber<? super T> subscriber)
  Subscriber<? super T>	OperatorOnErrorFlatMap.call(Subscriber<? super T> child)
  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>	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)
  Subscriber<? super T>	OperatorDefaultIfEmpty.call(Subscriber<? super T> child)
  Subscriber<? super Observable<? extends T>>	OperatorMergeMaxConcurrent.call(Subscriber<? super T> child)
  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>	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>	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)
  void	OnSubscribeMulticastSelector.call(Subscriber<? super TResult> child)

• 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 Rx 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.

  Constructors in rx.observers with parameters of type Subscriber

  Constructor and Description
  	SafeSubscriber(Subscriber<? super T> actual)
  	SerializedSubscriber(Subscriber<? super T> s)
  	TestSubscriber(Subscriber<T> delegate)