Packages that use Observer

• Uses of Observer in rx

  Classes in that implement

  Modifier and Type	Class and Description
  class	Subscriber<T> Provides a mechanism for receiving push-based notifications from Observables, and permits manual unsubscribing from these Observables.

  Methods in rx with parameters of type Observer

  Modifier and Type	Method and Description
  void	Notification.accept(Observer<? super T> observer) Forwards this notification on to a specified Observer.
  Observable<T>	Observable.doOnEach(Observer<? super T> observer) Modifies the source Observable so that it notifies an Observer for each item it emits.
  Subscription	Observable.subscribe(Observer<? super T> observer) Subscribes to an Observable and provides an Observer that implements functions to handle the items the Observable emits and any error or completion notification it issues.

• Uses of Observer in rx.internal.operators

  Classes in that implement

  Modifier and Type	Class and Description
  class	BufferUntilSubscriber<T> A solution to the "time gap" problem that occurs with groupBy and pivot.
  static class	OperatorReplay.SubjectWrapper<T> A subject that wraps another subject.

  Methods in with parameters of type

  Modifier and Type	Method and Description
  boolean	NotificationLite.accept(Observer<? super T> o, Object n) Unwraps the lite notification and calls the appropriate method on the Observer.

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

  Constructor and Description
  	OperatorDoOnEach(Observer<? super T> doOnEachObserver)

• Uses of Observer in rx.internal.util

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

  Modifier and Type	Method and Description
  boolean	RxRingBuffer.accept(Object o, Observer child)

• Uses of Observer in rx.observers

  Classes in that implement

  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	SerializedObserver<T> Enforces single-threaded, serialized, ordered execution of SerializedObserver.onNext(T), SerializedObserver.onCompleted(), and SerializedObserver.onError(java.lang.Throwable).
  class	SerializedSubscriber<T> Enforces single-threaded, serialized, ordered execution of SerializedSubscriber.onNext(T), SerializedSubscriber.onCompleted(), and SerializedSubscriber.onError(java.lang.Throwable).
  class	TestObserver<T> Observer usable for unit testing to perform assertions, inspect received events or wrap a mocked Observer.
  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> Observer<T>	Observers.create(Action1<? super T> onNext) Creates an Observer 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> Observer<T>	Observers.create(Action1<? super T> onNext, Action1<Throwable> onError) Creates an Observer that receives the emissions of any Observable it subscribes to via onNext and handles any onError notification but ignores an onCompleted notification.
  static <T> Observer<T>	Observers.create(Action1<? super T> onNext, Action1<Throwable> onError, Action0 onComplete) Creates an Observer that receives the emissions of any Observable it subscribes to via onNext and handles any onError or onCompleted notifications.
  static <T> Observer<T>	Observers.empty() Returns an inert Observer that does nothing in response to the emissions or notifications from any Observable it subscribes to but will throw an exception if its onError method is called.

  Methods in with parameters of type

  Modifier and Type	Method and Description
  static <T> Subscriber<T>	Subscribers.from(Observer<? super T> o) Converts an Observer into a Subscriber.

  Constructors in rx.observers with parameters of type Observer

  Constructor and Description
  	SerializedObserver(Observer<? super T> s)
  	TestObserver(Observer<T> delegate)
  	TestSubscriber(Observer<T> delegate)

• Uses of Observer in rx.subjects

  Classes in rx.subjects that implement Observer

  Modifier and Type	Class and Description
  class	AsyncSubject<T> Subject that publishes only the last item observed to each Observer that has subscribed, when the source Observable completes.
  class	BehaviorSubject<T> Subject that emits the most recent item it has observed and all subsequent observed items to each subscribed Observer.
  class	PublishSubject<T> Subject that, once an Observer has subscribed, emits all subsequently observed items to the subscriber.
  class	ReplaySubject<T> Subject that buffers all items it observes and replays them to any Observer that subscribes.
  class	SerializedSubject<T,R> Wraps a Subject so that it is safe to call its various on methods from different threads.
  class	Subject<T,R> Represents an object that is both an Observable and an Observer.
  class	TestSubject<T> A variety of Subject that is useful for testing purposes.