Package rx.observers

Class TestObserver<T>

java.lang.Object
rx.observers.TestObserver<T>
Type Parameters:
T - the observed value type
All Implemented Interfaces:
Observer<T>
@Deprecated public class TestObserver<T> extends Object implements Observer<T>
Deprecated.
use the TestSubscriber insteand.
Observer usable for unit testing to perform assertions, inspect received events or wrap a mocked Observer.

  • Field Details

    • delegate

      private final Observer<T> delegate
      Deprecated.

    • onNextEvents

      private final List<T> onNextEvents
      Deprecated.

    • onErrorEvents

      private final List<Throwable> onErrorEvents
      Deprecated.

    • onCompletedEvents

      private final List<Notification<T>> onCompletedEvents
      Deprecated.

    • INERT

      private static final Observer<Object> INERT
      Deprecated.

  • Constructor Details

    • TestObserver

      public TestObserver(Observer<T> delegate)
      Deprecated.

    • TestObserver

      public TestObserver()
      Deprecated.

  • Method Details

    • onCompleted

      public void onCompleted()
      Deprecated.
      Description copied from interface: Observer
      Notifies the Observer that the Observable has finished sending push-based notifications.

      The Observable will not call this method if it calls Observer.onError(java.lang.Throwable).

      Specified by:
      onCompleted in interface Observer<T>

    • getOnCompletedEvents

      public List<Notification<T>> getOnCompletedEvents()
      Deprecated.
      Get the Notifications representing each time this observer was notified of sequence completion via onCompleted(), as a List.
      Returns:
      a list of Notifications representing calls to this observer's onCompleted() method

    • onError

      public void onError(Throwable e)
      Deprecated.
      Description copied from interface: Observer
      Notifies the Observer that the Observable has experienced an error condition.

      If the Observable calls this method, it will not thereafter call Observer.onNext(T) or Observer.onCompleted().

      Specified by:
      onError in interface Observer<T>
      Parameters:
      e - the exception encountered by the Observable

    • getOnErrorEvents

      public List<Throwable> getOnErrorEvents()
      Deprecated.
      Get the Throwables this observer was notified of via onError(java.lang.Throwable) as a List.
      Returns:
      a list of Throwables passed to this observer's onError(java.lang.Throwable) method

    • onNext

      public void onNext(T t)
      Deprecated.
      Description copied from interface: Observer
      Provides the Observer with a new item to observe.

      The Observable may call this method 0 or more times.

      The Observable will not call this method again after it calls either Observer.onCompleted() or Observer.onError(java.lang.Throwable).

      Specified by:
      onNext in interface Observer<T>
      Parameters:
      t - the item emitted by the Observable

    • getOnNextEvents

      public List<T> getOnNextEvents()
      Deprecated.
      Get the sequence of items observed by this observer, as an ordered List.
      Returns:
      a list of items observed by this observer, in the order in which they were observed

    • getEvents

      public List<Object> getEvents()
      Deprecated.
      Get a list containing all of the items and notifications received by this observer, where the items will be given as-is, any error notifications will be represented by their Throwables, and any sequence-complete notifications will be represented by their Notification objects.
      Returns:
      a List containing one item for each item or notification received by this observer, in the order in which they were observed or received

    • assertReceivedOnNext

      public void assertReceivedOnNext(List<T> items)
      Deprecated.
      Assert that a particular sequence of items was received in order.
      Parameters:
      items - the sequence of items expected to have been observed
      Throws:
      AssertionError - if the sequence of items observed does not exactly match items

    • assertTerminalEvent

      public void assertTerminalEvent()
      Deprecated.
      Assert that a single terminal event occurred, either onCompleted() or onError(java.lang.Throwable).
      Throws:
      AssertionError - if not exactly one terminal event notification was received

    • assertionError

      final void assertionError(String message)
      Deprecated.
      Combines an assertion error message with the current completion and error state of this TestSubscriber, giving more information when some assertXXX check fails.
      Parameters:
      message - the message to use for the error