rxjava 1.3.8 · rx.observers.TestSubscriber

Modifier and Type	Field and Description
private int	completions The number of onCompleted() calls.
private final Observer<T>	delegate
private final List<Throwable>	errors
private static final Observer<Object>	INERT The shared no-op observer.
private volatile Thread	lastSeenThread
private final CountDownLatch	latch
private volatile int	valueCount Written after an onNext value has been added to the `values` list.
private final List<T>	values

Access	Constructor and Description
public	TestSubscriber(long the initial request value, negative value will revert to the default unbounded behavior initialRequest) Constructs a TestSubscriber with the initial request to be requested from upstream.
public	TestSubscriber(Observer<T> the Observer instance to wrap delegate, long the initial request value, negative value will revert to the default unbounded behavior initialRequest) Constructs a TestSubscriber with the initial request to be requested from upstream and a delegate Observer to wrap.
public	TestSubscriber(Subscriber<T> the subscriber to delegate to. delegate) Constructs a TestSubscriber which requests Long.MAX_VALUE and delegates events to the given Subscriber.
public	TestSubscriber(Observer<T> the observer to delegate to. delegate) Constructs a TestSubscriber which requests Long.MAX_VALUE and delegates events to the given Observer.
public	TestSubscriber() Constructs a TestSubscriber with an initial request of Long.MAX_VALUE and no delegation.

Method Summary

Modifier and Type	Method and Description
public void	assertCompleted() Asserts that there is exactly one completion event.
public void	assertError(Class<? extends Throwable> the class to check the error against. clazz) Asserts that there is exactly one error event which is a subclass of the given class.
public void	assertError(Throwable the throwable to check throwable) Asserts that there is a single onError event with the exact exception.
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.
private void	assertItem(T expected, int i)
public void	assertNoErrors() Asserts that this `Subscriber` has received no `onError` notifications.
public void	assertNotCompleted() Asserts that there is no completion event.
public void	assertNoTerminalEvent() Asserts that there are no onError and onCompleted events.
public void	assertNoValues() Asserts that there are no onNext events received.
public void	assertReceivedOnNext(List<T> the sequence of items expected to have been observed items) Asserts that a particular sequence of items was received by this `Subscriber` in order.
public void	assertTerminalEvent() Asserts that a single terminal event occurred, either `onCompleted` or `onError`.
public void	assertUnsubscribed() Asserts that this `Subscriber` is unsubscribed.
public void	assertValue(T the item to check value) Asserts that there is only a single received onNext event and that it marks the emission of a specific item.
public void	assertValueCount(int the expected number of onNext events count) Asserts that the given number of onNext events are received.
public void	assertValues(T... the items to check values) Asserts that the received onNext events, in order, are the specified items.
public final void	assertValuesAndClear(T the expected first value expectedFirstValue, T... the optional rest values expectedRestValues) Assert that the TestSubscriber contains the given first and optional rest values exactly and if so, clears the internal list of values.
public void	awaitTerminalEvent() Blocks until this `Subscriber` receives a notification that the `Observable` is complete (either an `onCompleted` or `onError` notification).
public void	awaitTerminalEvent(long the duration of the timeout timeout, TimeUnit the units in which `timeout` is expressed unit) Blocks until this `Subscriber` receives a notification that the `Observable` is complete (either an `onCompleted` or `onError` notification), or until a timeout expires.
public void	awaitTerminalEventAndUnsubscribeOnTimeout(long the duration of the timeout timeout, TimeUnit the units in which `timeout` is expressed unit) Blocks until this `Subscriber` receives a notification that the `Observable` is complete (either an `onCompleted` or `onError` notification), or until a timeout expires; if the Subscriber is interrupted before either of these events take place, this method unsubscribes the Subscriber from the Observable).
public final boolean	Returns: true if the expected number of onNext events happened awaitValueCount(int the expected number of onNext events expected, long the time to wait for the events timeout, TimeUnit the time unit of waiting unit) Wait until the current committed value count is less than the expected amount by sleeping 1 unit at most timeout times and return true if at least the required amount of onNext values have been received.
public static < the value type T> TestSubscriber<T>	Returns: the created TestSubscriber instance create() Factory method to construct a TestSubscriber with an initial request of Long.MAX_VALUE and no delegation.
public static < the value type T> TestSubscriber<T>	Returns: the created TestSubscriber instance create(long the initial request amount, negative values revert to the default unbounded mode initialRequest) Factory method to construct a TestSubscriber with the given initial request amount and no delegation.
public static < the value type T> TestSubscriber<T>	Returns: the created TestSubscriber instance create(Observer<T> the observer to delegate events to delegate, long the initial request amount, negative values revert to the default unbounded mode initialRequest) Factory method to construct a TestSubscriber which delegates events to the given Observer and issues the given initial request amount.
public static < the value type T> TestSubscriber<T>	Returns: the created TestSubscriber instance create(Subscriber<T> the subscriber to delegate events to delegate) Factory method to construct a TestSubscriber which delegates events to the given Subscriber and an issues an initial request of Long.MAX_VALUE.
public static < the value type T> TestSubscriber<T>	Returns: the created TestSubscriber instance create(Observer<T> the observer to delegate events to delegate) Factory method to construct a TestSubscriber which delegates events to the given Observer and an issues an initial request of Long.MAX_VALUE.
public final int	Returns: the number of times onCompleted was called on this TestSubscriber. getCompletions() Returns the number of times onCompleted was called on this TestSubscriber.
public Thread	Returns: the `Thread` on which this Subscriber last received an item or notification from the Observable it is subscribed to getLastSeenThread() Returns the last thread that was in use when an item or notification was received by this `Subscriber`.
public List<Notification<T>>	Returns: a list of Notifications representing calls to this Subscriber's `onCompleted` method getOnCompletedEvents() Deprecated use `getCompletions()` instead. Returns the `Notification`s representing each time this `Subscriber` was notified of sequence completion via `onCompleted`, as a `List`.
public List<Throwable>	Returns: a list of the Throwables that were passed to this Subscriber's `onError` method getOnErrorEvents() Returns the `Throwable`s this `Subscriber` was notified of via `onError` as a `List`.
public List<T>	Returns: a list of items observed by this Subscriber, in the order in which they were observed getOnNextEvents() Returns the sequence of items observed by this `Subscriber`, as an ordered `List`.
public final int	Returns: the committed number of onNext elements getValueCount() Returns the committed number of onNext elements that are safe to be read from `getOnNextEvents()` other threads.
public void	onCompleted() Implements rx.Observer.onCompleted. Notifies the Subscriber 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 Subscriber 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 Subscriber with a new item to observe.
public void	requestMore(long the maximum number of items you want the Observable to emit to the Subscriber at this time, or `Long.MAX_VALUE` if you want the Observable to emit items at its own pace n) Allows calling the protected `request(long)` from unit tests.

Inherited from rx.Subscriber:: add isUnsubscribed onStart request setProducer unsubscribe

completions	back to summary
private int completions The number of onCompleted() calls.

delegate	back to summary
private final Observer<T> delegate

errors	back to summary
private final List<Throwable> errors

INERT	back to summary
private static final Observer<Object> INERT The shared no-op observer.

lastSeenThread	back to summary
private volatile Thread lastSeenThread

latch	back to summary
private final CountDownLatch latch

valueCount	back to summary
private volatile int valueCount Written after an onNext value has been added to the `values` list.

values	back to summary
private final List<T> values

TestSubscriber	back to summary
public TestSubscriber(long initialRequest) Constructs a TestSubscriber with the initial request to be requested from upstream. Parameters initialRequest:long the initial request value, negative value will revert to the default unbounded behavior Annotations @SuppressWarnings:unchecked Since 1.1.0

TestSubscriber	back to summary
public TestSubscriber(Observer<T> delegate, long initialRequest) Constructs a TestSubscriber with the initial request to be requested from upstream and a delegate Observer to wrap. Parameters delegate:Observer<T> the Observer instance to wrap initialRequest:long the initial request value, negative value will revert to the default unbounded behavior Exceptions NullPointerException: if delegate is null Since 1.1.0

TestSubscriber	back to summary
public TestSubscriber(Subscriber<T> delegate) Constructs a TestSubscriber which requests Long.MAX_VALUE and delegates events to the given Subscriber. Parameters delegate:Subscriber<T> the subscriber to delegate to. Exceptions NullPointerException: if delegate is null Since 1.1.0

TestSubscriber	back to summary
public TestSubscriber(Observer<T> delegate) Constructs a TestSubscriber which requests Long.MAX_VALUE and delegates events to the given Observer. Parameters delegate:Observer<T> the observer to delegate to. Exceptions NullPointerException: if delegate is null Since 1.1.0

TestSubscriber	back to summary
public TestSubscriber() Constructs a TestSubscriber with an initial request of Long.MAX_VALUE and no delegation.

Method Detail

assertCompleted	back to summary
public void assertCompleted() Asserts that there is exactly one completion event. Exceptions AssertionError: if there were zero, or more than one, onCompleted events Since 1.1.0

assertCompleted

back to summary

public void assertCompleted()

Asserts that there is exactly one completion event.

Exceptions

AssertionError:: if there were zero, or more than one, onCompleted events

Since

1.1.0

assertError	back to summary
public void assertError(Class<? extends Throwable> clazz) Asserts that there is exactly one error event which is a subclass of the given class. Parameters clazz:Class<? extends Throwable> the class to check the error against. Exceptions AssertionError: if there were zero, or more than one, onError events, or if the single onError event did not carry an error of a subclass of the given class Since 1.1.0

assertError

back to summary

public void assertError(Class<? extends Throwable> clazz)

Asserts that there is exactly one error event which is a subclass of the given class.

Parameters

clazz:Class<? extends Throwable>: the class to check the error against.

Exceptions

AssertionError:: if there were zero, or more than one, onError events, or if the single onError event did not carry an error of a subclass of the given class

Since

1.1.0

assertError	back to summary
public void assertError(Throwable throwable) Asserts that there is a single onError event with the exact exception. Parameters throwable:Throwable the throwable to check Exceptions AssertionError: if there were zero, or more than one, onError events, or if the single onError event did not carry an error that matches the specified throwable Since 1.1.0

assertError

back to summary

public void assertError(Throwable throwable)

Asserts that there is a single onError event with the exact exception.

Parameters

throwable:Throwable: the throwable to check

Exceptions

AssertionError:: if there were zero, or more than one, onError events, or if the single onError event did not carry an error that matches the specified throwable

Since

1.1.0

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

assertItem	back to summary
private void assertItem(T expected, int i)

assertNoErrors back to summary

assertNoErrors	back to summary
public void assertNoErrors() Asserts that this `Subscriber` has received no `onError` notifications. Exceptions AssertionError: if this `Subscriber` has received one or more `onError` notifications

public void assertNoErrors()

Asserts that this Subscriber has received no onError notifications.

Exceptions

AssertionError:: if this Subscriber has received one or more onError notifications

assertNotCompleted	back to summary
public void assertNotCompleted() Asserts that there is no completion event. Exceptions AssertionError: if there were one or more than one onCompleted events Since 1.1.0

assertNotCompleted

back to summary

public void assertNotCompleted()

Asserts that there is no completion event.

Exceptions

AssertionError:: if there were one or more than one onCompleted events

Since

1.1.0

assertNoTerminalEvent	back to summary
public void assertNoTerminalEvent() Asserts that there are no onError and onCompleted events. Exceptions AssertionError: if there was either an onError or onCompleted event Since 1.1.0

assertNoTerminalEvent

back to summary

public void assertNoTerminalEvent()

Asserts that there are no onError and onCompleted events.

Exceptions

AssertionError:: if there was either an onError or onCompleted event

Since

1.1.0

assertNoValues	back to summary
public void assertNoValues() Asserts that there are no onNext events received. Exceptions AssertionError: if there were any onNext events Since 1.1.0

assertNoValues

back to summary

public void assertNoValues()

Asserts that there are no onNext events received.

Exceptions

AssertionError:: if there were any onNext events

Since

1.1.0

assertReceivedOnNext back to summary

assertReceivedOnNext	back to summary
public void assertReceivedOnNext(List<T> items) Asserts that a particular sequence of items was received by this `Subscriber` 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)

Asserts that a particular sequence of items was received by this Subscriber 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() Asserts that a single terminal event occurred, either `onCompleted` or `onError`. Exceptions AssertionError: if not exactly one terminal event notification was received

public void assertTerminalEvent()

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

Exceptions

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

assertUnsubscribed back to summary

assertUnsubscribed	back to summary
public void assertUnsubscribed() Asserts that this `Subscriber` is unsubscribed. Exceptions AssertionError: if this `Subscriber` is not unsubscribed

public void assertUnsubscribed()

Asserts that this Subscriber is unsubscribed.

Exceptions

AssertionError:: if this Subscriber is not unsubscribed

assertValue back to summary

assertValue	back to summary
public void assertValue(T value) Asserts that there is only a single received onNext event and that it marks the emission of a specific item. Parameters value:T the item to check Exceptions AssertionError: if the Observable does not emit only the single item specified by `value` Since 1.1.0

public void assertValue(T value)

Asserts that there is only a single received onNext event and that it marks the emission of a specific item.

Parameters

value:T: the item to check

Exceptions

AssertionError:: if the Observable does not emit only the single item specified by value

Since

1.1.0

assertValueCount back to summary

assertValueCount	back to summary
public void assertValueCount(int count) Asserts that the given number of onNext events are received. Parameters count:int the expected number of onNext events Exceptions AssertionError: if there were more or fewer onNext events than specified by `count` Since 1.1.0

public void assertValueCount(int count)

Asserts that the given number of onNext events are received.

Parameters

count:int: the expected number of onNext events

Exceptions

AssertionError:: if there were more or fewer onNext events than specified by count

Since

1.1.0

assertValues back to summary

assertValues	back to summary
public void assertValues(T... values) Asserts that the received onNext events, in order, are the specified items. Parameters values:T[] the items to check Exceptions AssertionError: if the items emitted do not exactly match those specified by `values` Since 1.1.0

public void assertValues(T... values)

Asserts that the received onNext events, in order, are the specified items.

Parameters

values:T[]: the items to check

Exceptions

AssertionError:: if the items emitted do not exactly match those specified by values

Since

1.1.0

assertValuesAndClear back to summary

assertValuesAndClear	back to summary
public final void assertValuesAndClear(T expectedFirstValue, T... expectedRestValues) Assert that the TestSubscriber contains the given first and optional rest values exactly and if so, clears the internal list of values. `TestSubscriber ts = new TestSubscriber(); ts.onNext(1); ts.assertValuesAndClear(1); ts.onNext(2); ts.onNext(3); ts.assertValuesAndClear(2, 3); // no mention of 1` Parameters expectedFirstValue:T the expected first value expectedRestValues:T[] the optional rest values Since 1.3

public final void assertValuesAndClear(T expectedFirstValue, T... expectedRestValues)

Assert that the TestSubscriber contains the given first and optional rest values exactly and if so, clears the internal list of values.

TestSubscriber ts = new TestSubscriber();

ts.onNext(1);

ts.assertValuesAndClear(1);

ts.onNext(2);
ts.onNext(3);

ts.assertValuesAndClear(2, 3); // no mention of 1

Parameters

expectedFirstValue:T: the expected first value
expectedRestValues:T[]: the optional rest values

Since

1.3

awaitTerminalEvent back to summary

awaitTerminalEvent	back to summary
public void awaitTerminalEvent() Blocks until this `Subscriber` receives a notification that the `Observable` is complete (either an `onCompleted` or `onError` notification). Exceptions RuntimeException: if the Subscriber is interrupted before the Observable is able to complete

public void awaitTerminalEvent()

Blocks until this Subscriber receives a notification that the Observable is complete (either an onCompleted or onError notification).

Exceptions

RuntimeException:: if the Subscriber is interrupted before the Observable is able to complete

awaitTerminalEvent back to summary

awaitTerminalEvent	back to summary
public void awaitTerminalEvent(long timeout, TimeUnit unit) Blocks until this `Subscriber` receives a notification that the `Observable` is complete (either an `onCompleted` or `onError` notification), or until a timeout expires. Parameters timeout:long the duration of the timeout unit:TimeUnit the units in which `timeout` is expressed Exceptions RuntimeException: if the Subscriber is interrupted before the Observable is able to complete

public void awaitTerminalEvent(long timeout, TimeUnit unit)

Blocks until this Subscriber receives a notification that the Observable is complete (either an onCompleted or onError notification), or until a timeout expires.

Parameters

timeout:long: the duration of the timeout
unit:TimeUnit: the units in which timeout is expressed

Exceptions

RuntimeException:: if the Subscriber is interrupted before the Observable is able to complete

awaitTerminalEventAndUnsubscribeOnTimeout back to summary

awaitTerminalEventAndUnsubscribeOnTimeout	back to summary
public void awaitTerminalEventAndUnsubscribeOnTimeout(long timeout, TimeUnit unit) Blocks until this `Subscriber` receives a notification that the `Observable` is complete (either an `onCompleted` or `onError` notification), or until a timeout expires; if the Subscriber is interrupted before either of these events take place, this method unsubscribes the Subscriber from the Observable). If timeout expires then the Subscriber is unsubscribed from the Observable. Parameters timeout:long the duration of the timeout unit:TimeUnit the units in which `timeout` is expressed

public void awaitTerminalEventAndUnsubscribeOnTimeout(long timeout, TimeUnit unit)

Blocks until this Subscriber receives a notification that the Observable is complete (either an onCompleted or onError notification), or until a timeout expires; if the Subscriber is interrupted before either of these events take place, this method unsubscribes the Subscriber from the Observable). If timeout expires then the Subscriber is unsubscribed from the Observable.

Parameters

timeout:long: the duration of the timeout
unit:TimeUnit: the units in which timeout is expressed

awaitValueCount	back to summary
public final boolean awaitValueCount(int expected, long timeout, TimeUnit unit) Wait until the current committed value count is less than the expected amount by sleeping 1 unit at most timeout times and return true if at least the required amount of onNext values have been received. Parameters expected:int the expected number of onNext events timeout:long the time to wait for the events unit:TimeUnit the time unit of waiting Returns:boolean true if the expected number of onNext events happened Exceptions RuntimeException: if the sleep is interrupted Since 1.3

awaitValueCount

back to summary

public final boolean awaitValueCount(int expected, long timeout, TimeUnit unit)

Wait until the current committed value count is less than the expected amount by sleeping 1 unit at most timeout times and return true if at least the required amount of onNext values have been received.

Parameters

expected:int: the expected number of onNext events
timeout:long: the time to wait for the events
unit:TimeUnit: the time unit of waiting

Returns:boolean

true if the expected number of onNext events happened

Exceptions

RuntimeException:: if the sleep is interrupted

Since

1.3

create	back to summary
public static <T> TestSubscriber<T> create() Factory method to construct a TestSubscriber with an initial request of Long.MAX_VALUE and no delegation. Parameters <T> the value type Returns:TestSubscriber<T> the created TestSubscriber instance Since 1.1.0

create

back to summary

public static <T> TestSubscriber<T> create()

Factory method to construct a TestSubscriber with an initial request of Long.MAX_VALUE and no delegation.

Parameters

<T>: the value type

Returns:TestSubscriber<T>

the created TestSubscriber instance

Since

1.1.0

create	back to summary
public static <T> TestSubscriber<T> create(long initialRequest) Factory method to construct a TestSubscriber with the given initial request amount and no delegation. Parameters <T> the value type initialRequest:long the initial request amount, negative values revert to the default unbounded mode Returns:TestSubscriber<T> the created TestSubscriber instance Since 1.1.0

create

back to summary

public static <T> TestSubscriber<T> create(long initialRequest)

Factory method to construct a TestSubscriber with the given initial request amount and no delegation.

Parameters

<T>: the value type
initialRequest:long: the initial request amount, negative values revert to the default unbounded mode

Returns:TestSubscriber<T>

the created TestSubscriber instance

Since

1.1.0

create	back to summary
public static <T> TestSubscriber<T> create(Observer<T> delegate, long initialRequest) Factory method to construct a TestSubscriber which delegates events to the given Observer and issues the given initial request amount. Parameters <T> the value type delegate:Observer<T> the observer to delegate events to initialRequest:long the initial request amount, negative values revert to the default unbounded mode Returns:TestSubscriber<T> the created TestSubscriber instance Exceptions NullPointerException: if delegate is null Since 1.1.0

create

back to summary

public static <T> TestSubscriber<T> create(Observer<T> delegate, long initialRequest)

Factory method to construct a TestSubscriber which delegates events to the given Observer and issues the given initial request amount.

Parameters

<T>: the value type
delegate:Observer<T>: the observer to delegate events to
initialRequest:long: the initial request amount, negative values revert to the default unbounded mode

Returns:TestSubscriber<T>

the created TestSubscriber instance

Exceptions

NullPointerException:: if delegate is null

Since

1.1.0

create	back to summary
public static <T> TestSubscriber<T> create(Subscriber<T> delegate) Factory method to construct a TestSubscriber which delegates events to the given Subscriber and an issues an initial request of Long.MAX_VALUE. Parameters <T> the value type delegate:Subscriber<T> the subscriber to delegate events to Returns:TestSubscriber<T> the created TestSubscriber instance Exceptions NullPointerException: if delegate is null Since 1.1.0

create

back to summary

public static <T> TestSubscriber<T> create(Subscriber<T> delegate)

Factory method to construct a TestSubscriber which delegates events to the given Subscriber and an issues an initial request of Long.MAX_VALUE.

Parameters

<T>: the value type
delegate:Subscriber<T>: the subscriber to delegate events to

Returns:TestSubscriber<T>

the created TestSubscriber instance

Exceptions

NullPointerException:: if delegate is null

Since

1.1.0

create	back to summary
public static <T> TestSubscriber<T> create(Observer<T> delegate) Factory method to construct a TestSubscriber which delegates events to the given Observer and an issues an initial request of Long.MAX_VALUE. Parameters <T> the value type delegate:Observer<T> the observer to delegate events to Returns:TestSubscriber<T> the created TestSubscriber instance Exceptions NullPointerException: if delegate is null Since 1.1.0

create

back to summary

public static <T> TestSubscriber<T> create(Observer<T> delegate)

Factory method to construct a TestSubscriber which delegates events to the given Observer and an issues an initial request of Long.MAX_VALUE.

Parameters

<T>: the value type
delegate:Observer<T>: the observer to delegate events to

Returns:TestSubscriber<T>

the created TestSubscriber instance

Exceptions

NullPointerException:: if delegate is null

Since

1.1.0

getCompletions	back to summary
public final int getCompletions() Returns the number of times onCompleted was called on this TestSubscriber. Returns:int the number of times onCompleted was called on this TestSubscriber. Since 1.3

getCompletions

back to summary

public final int getCompletions()

Returns the number of times onCompleted was called on this TestSubscriber.

Returns:int: the number of times onCompleted was called on this TestSubscriber.
Since: 1.3

getLastSeenThread back to summary

getLastSeenThread	back to summary
public Thread getLastSeenThread() Returns the last thread that was in use when an item or notification was received by this `Subscriber`. Returns:Thread the `Thread` on which this Subscriber last received an item or notification from the Observable it is subscribed to

public Thread getLastSeenThread()

Returns the last thread that was in use when an item or notification was received by this Subscriber.

Returns:Thread: the Thread on which this Subscriber last received an item or notification from the Observable it is subscribed to

getOnCompletedEvents back to summary

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

public List<Notification<T>> getOnCompletedEvents()

Deprecated

use getCompletions() instead.

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

Returns:List<Notification<T>>

a list of Notifications representing calls to this Subscriber's onCompleted method

Annotations

@Deprecated

getOnErrorEvents back to summary

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

public List<Throwable> getOnErrorEvents()

Returns the Throwables this Subscriber was notified of via onError as a List.

Returns:List<Throwable>: a list of the Throwables that were passed to this Subscriber's onError method

getOnNextEvents back to summary

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

public List<T> getOnNextEvents()

Returns the sequence of items observed by this Subscriber, as an ordered List.

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

getValueCount back to summary

getValueCount	back to summary
public final int getValueCount() Returns the committed number of onNext elements that are safe to be read from `getOnNextEvents()` other threads. Returns:int the committed number of onNext elements

public final int getValueCount()

Returns the committed number of onNext elements that are safe to be read from getOnNextEvents() other threads.

Returns:int: the committed number of onNext elements

onCompleted back to summary

onCompleted	back to summary
public void onCompleted() Implements rx.Observer.onCompleted. Notifies the Subscriber 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.

Notifies the Subscriber 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. Notifies the Subscriber 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.

Notifies the Subscriber 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. Provides the Subscriber 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.

Provides the Subscriber 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

requestMore back to summary

public void requestMore(long n)

Allows calling the protected request(long) from unit tests.

Parameters

n:long: the maximum number of items you want the Observable to emit to the Subscriber at this time, or Long.MAX_VALUE if you want the Observable to emit items at its own pace

public Class TestSubscriber<T>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail