rxjava 1.3.8 · rx.observers.TestObserver

Modifier and Type	Field and Description
private final Observer<T>	delegate
private static final Observer<Object>	INERT
private final List<Notification<T>>	onCompletedEvents
private final List<Throwable>	onErrorEvents
private final List<T>	onNextEvents

Access	Constructor and Description
public	TestObserver(Observer<T> delegate)
public	TestObserver()

Method Summary

Modifier and Type	Method and Description
pack-priv final void	assertionError(String the message to use for the error message) Combines an assertion error message with the current completion and error state of this TestSubscriber, giving more information when some assertXXX check fails.
public void	assertReceivedOnNext(List<T> the sequence of items expected to have been observed items) Assert that a particular sequence of items was received in order.
public void	assertTerminalEvent() Assert that a single terminal event occurred, either `onCompleted` or `onError`.
public List<Object>	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 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.
public List<Notification<T>>	Returns: a list of Notifications representing calls to this observer's `onCompleted` method getOnCompletedEvents() Get the `Notification`s representing each time this observer was notified of sequence completion via `onCompleted`, as a `List`.
public List<Throwable>	Returns: a list of Throwables passed to this observer's `onError` method getOnErrorEvents() Get the `Throwable`s this observer was notified of via `onError` as a `List`.
public List<T>	Returns: a list of items observed by this observer, in the order in which they were observed getOnNextEvents() Get the sequence of items observed by this observer, as an ordered `List`.
public void	onCompleted() Implements rx.Observer.onCompleted. Notifies the Observer that the `Observable` has finished sending push-based notifications.
public void	onError(Throwable the exception encountered by the Observable e) Implements rx.Observer.onError. Notifies the Observer that the `Observable` has experienced an error condition.
public void	onNext(T the item emitted by the Observable t) Implements rx.Observer.onNext. Provides the Observer with a new item to observe.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

delegate	back to summary
private final Observer<T> delegate

INERT	back to summary
private static final Observer<Object> INERT

onCompletedEvents	back to summary
private final List<Notification<T>> onCompletedEvents

onErrorEvents	back to summary
private final List<Throwable> onErrorEvents

onNextEvents	back to summary
private final List<T> onNextEvents

TestObserver	back to summary
public TestObserver(Observer<T> delegate)

TestObserver	back to summary
public TestObserver() Annotations @SuppressWarnings:unchecked

Method Detail

assertionError	back to summary
pack-priv final void assertionError(String message) 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:String the message to use for the error

assertionError

back to summary

pack-priv final void assertionError(String message)

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:String: the message to use for the error

assertReceivedOnNext back to summary

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

public void assertReceivedOnNext(List<T> items)

Assert that a particular sequence of items was received in order.

Parameters

items:List<T>: the sequence of items expected to have been observed

Exceptions

AssertionError:: if the sequence of items observed does not exactly match items

assertTerminalEvent back to summary

assertTerminalEvent	back to summary
public void assertTerminalEvent() Assert that a single terminal event occurred, either `onCompleted` or `onError`. Exceptions AssertionError: if not exactly one terminal event notification was received

public void assertTerminalEvent()

Assert that a single terminal event occurred, either onCompleted or onError.

Exceptions

AssertionError:: if not exactly one terminal event notification was received

getEvents back to summary

getEvents	back to summary
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 `Throwable`s, and any sequence-complete notifications will be represented by their `Notification` objects. Returns:List<Object> a `List` containing one item for each item or notification received by this observer, in the order in which they were observed or received

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:List<Object>: a List containing one item for each item or notification received by this observer, in the order in which they were observed or received

getOnCompletedEvents back to summary

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

public List<Notification<T>> getOnCompletedEvents()

Get the Notifications representing each time this observer was notified of sequence completion via onCompleted, as a List.

Returns:List<Notification<T>>: a list of Notifications representing calls to this observer's onCompleted method

getOnErrorEvents back to summary

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

public List<Throwable> getOnErrorEvents()

Get the Throwables this observer was notified of via onError as a List.

Returns:List<Throwable>: a list of Throwables passed to this observer's onError method

getOnNextEvents back to summary

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

public List<T> getOnNextEvents()

Get the sequence of items observed by this observer, as an ordered List.

Returns:List<T>: a list of items observed by this observer, in the order in which they were observed

onCompleted back to summary

onCompleted	back to summary
public void onCompleted() Implements rx.Observer.onCompleted. Doc from rx.Observer.onCompleted. Notifies the Observer that the `Observable` has finished sending push-based notifications. The `Observable` will not call this method if it calls `onError`. Annotations @Override

public void onCompleted()

Implements rx.Observer.onCompleted.

Doc from rx.Observer.onCompleted.

Notifies the Observer that the Observable has finished sending push-based notifications.

The Observable will not call this method if it calls onError.

Annotations

@Override

onError back to summary

onError	back to summary
public void onError(Throwable e) Implements rx.Observer.onError. Doc from rx.Observer.onError. Notifies the Observer that the `Observable` has experienced an error condition. If the `Observable` calls this method, it will not thereafter call `onNext` or `onCompleted`. Parameters e:Throwable the exception encountered by the Observable Annotations @Override

public void onError(Throwable e)

Implements rx.Observer.onError.

Doc from rx.Observer.onError.

Notifies the Observer that the Observable has experienced an error condition.

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

Parameters

e:Throwable: the exception encountered by the Observable

Annotations

@Override

onNext back to summary

onNext	back to summary
public void onNext(T t) Implements rx.Observer.onNext. Doc from rx.Observer.onNext. 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 `onCompleted` or `onError`. Parameters t:T the item emitted by the Observable Annotations @Override

public void onNext(T t)

Implements rx.Observer.onNext.

Doc from rx.Observer.onNext.

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 onCompleted or onError.

Parameters

t:T: the item emitted by the Observable

Annotations

@Override

public Class TestObserver<T>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail