TestObserver

java.lang.Object
- rx.observers.TestObserver<T>

All Implemented Interfaces:

Observer<T>
```
public class TestObserver<T>
extends Object
implements Observer<T>
```
Observer usable for unit testing to perform assertions, inspect received events or wrap a mocked Observer.

Constructor Summary

Constructors

Constructor and Description
`TestObserver()`
`TestObserver(Observer<T> delegate)`

Method Summary

All Methods

Instance Methods

Concrete Methods
Modifier and Type	Method and Description
`void`	`assertReceivedOnNext(List<T> items)` Assert that a particular sequence of items was received in order.
`void`	`assertTerminalEvent()` Assert that a single terminal event occurred, either `onCompleted()` or `onError(java.lang.Throwable)`.
`List<Object>`	`getEvents()` 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 `Throwable`s, and any sequence-complete notifications will be represented by their `Notification` objects.
`List<Notification<T>>`	`getOnCompletedEvents()` Get the `Notification`s representing each time this observer was notified of sequence completion via `onCompleted()`, as a `List`.
`List<Throwable>`	`getOnErrorEvents()` Get the `Throwable`s this observer was notified of via `onError(java.lang.Throwable)` as a `List`.
`List<T>`	`getOnNextEvents()` Get the sequence of items observed by this observer, as an ordered `List`.
`void`	`onCompleted()` Notifies the Observer that the `Observable` has finished sending push-based notifications.
`void`	`onError(Throwable e)` Notifies the Observer that the `Observable` has experienced an error condition.
`void`	`onNext(T t)` Provides the Observer with a new item to observe.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - TestObserver
```
public TestObserver(Observer<T> delegate)
```
  - TestObserver
```
public TestObserver()
```
- Method Detail
  - onCompleted
```
public void onCompleted()
```
    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).
  - getOnCompletedEvents
```
public List<Notification<T>> getOnCompletedEvents()
```
    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)
```
    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()
```
    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)
```
    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()
```
    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()
```
    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)
```
    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()
```
    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

Class TestObserver<T>

Constructor Summary

Constructors

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

TestObserver

TestObserver

Method Detail

onCompleted

getOnCompletedEvents

onError

getOnErrorEvents

onNext

getOnNextEvents

getEvents

assertReceivedOnNext

assertTerminalEvent