TestSubscriber (RxJava Javadoc 2.0.6)

java.lang.Object
- io.reactivex.observers.BaseTestConsumer<T,TestSubscriber<T>>
- - io.reactivex.subscribers.TestSubscriber<T>

Type Parameters:
T - the value type

All Implemented Interfaces:

Disposable, org.reactivestreams.Subscriber<T>, org.reactivestreams.Subscription
```
public class TestSubscriber<T>
extends BaseTestConsumer<T,TestSubscriber<T>>
implements org.reactivestreams.Subscriber<T>, org.reactivestreams.Subscription, Disposable
```
A subscriber that records events and allows making assertions about them.
You can override the onSubscribe, onNext, onError, onComplete, request and cancel methods but not the others (this is by design).
The TestSubscriber implements Disposable for convenience where dispose calls cancel.
When calling the default request method, you are requesting on behalf of the wrapped actual subscriber.

Field Summary
- Fields inherited from class io.reactivex.observers.BaseTestConsumer
  checkSubscriptionOnce, completions, done, errors, establishedFusionMode, initialFusionMode, lastThread, values

Constructor Summary

Constructors
Constructor and Description
`TestSubscriber()` Constructs a non-forwarding TestSubscriber with an initial request value of Long.MAX_VALUE.
`TestSubscriber(long initialRequest)` Constructs a non-forwarding TestSubscriber with the specified initial request value.
`TestSubscriber(org.reactivestreams.Subscriber<? super T> actual)` Constructs a forwarding TestSubscriber but leaves the requesting to the wrapped subscriber.
`TestSubscriber(org.reactivestreams.Subscriber<? super T> actual, long initialRequest)` Constructs a forwarding TestSubscriber with the specified initial request value.

Method Summary

Methods
Modifier and Type	Method and Description
`TestSubscriber<T>`	`assertNotSubscribed()` Assert that the onSubscribe method hasn't been called at all.
`TestSubscriber<T>`	`assertOf(Consumer<? super TestSubscriber<T>> check)` Run a check consumer with this TestSubscriber instance.
`TestSubscriber<T>`	`assertSubscribed()` Assert that the onSubscribe method was called exactly once.
`void`	`cancel()`
`static <T> TestSubscriber<T>`	`create()` Creates a TestSubscriber with Long.MAX_VALUE initial request.
`static <T> TestSubscriber<T>`	`create(long initialRequested)` Creates a TestSubscriber with the given initial request.
`static <T> TestSubscriber<T>`	`create(org.reactivestreams.Subscriber<? super T> delegate)` Constructs a forwarding TestSubscriber.
`void`	`dispose()` Dispose the resource, the operation should be idempotent.
`boolean`	`hasSubscription()` Returns true if this TestSubscriber received a subscription.
`boolean`	`isCancelled()` Returns true if this TestSubscriber has been cancelled.
`boolean`	`isDisposed()` Returns true if this resource has been disposed.
`void`	`onComplete()`
`void`	`onError(java.lang.Throwable t)`
`void`	`onNext(T t)`
`protected void`	`onStart()` Called after the onSubscribe is called and handled.
`void`	`onSubscribe(org.reactivestreams.Subscription s)`
`void`	`request(long n)`
`TestSubscriber<T>`	`requestMore(long n)` Calls `request(long)` and returns this.

Methods inherited from class io.reactivex.observers.BaseTestConsumer
assertComplete, assertEmpty, assertError, assertError, assertError, assertErrorMessage, assertFailure, assertFailure, assertFailureAndMessage, assertNever, assertNever, assertNoErrors, assertNotComplete, assertNotTerminated, assertNoValues, assertResult, assertTerminated, assertValue, assertValue, assertValueAt, assertValueCount, assertValues, assertValueSequence, assertValueSet, await, await, awaitDone, awaitTerminalEvent, awaitTerminalEvent, completions, errorCount, errors, fail, getEvents, isTerminated, lastThread, valueAndClass, valueCount, values

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

- Constructor Detail
  - TestSubscriber
```
public TestSubscriber()
```
    Constructs a non-forwarding TestSubscriber with an initial request value of Long.MAX_VALUE.
  - TestSubscriber
```
public TestSubscriber(long initialRequest)
```
    Constructs a non-forwarding TestSubscriber with the specified initial request value.
    The TestSubscriber doesn't validate the initialRequest value so one can test sources with invalid values as well.
    
    Parameters:
    initialRequest - the initial request value
  - TestSubscriber
```
public TestSubscriber(org.reactivestreams.Subscriber<? super T> actual)
```
    Constructs a forwarding TestSubscriber but leaves the requesting to the wrapped subscriber.
    
    Parameters:
    actual - the actual Subscriber to forward events to
  - TestSubscriber
```
public TestSubscriber(org.reactivestreams.Subscriber<? super T> actual,
              long initialRequest)
```
    Constructs a forwarding TestSubscriber with the specified initial request value.
    The TestSubscriber doesn't validate the initialRequest value so one can test sources with invalid values as well.
    
    Parameters:
    actual - the actual Subscriber to forward events to
    initialRequest - the initial request value
- Method Detail
  - create
```
public static <T> TestSubscriber<T> create()
```
    Creates a TestSubscriber with Long.MAX_VALUE initial request.
    
    Type Parameters:
    T - the value type
    
    Returns:
    the new TestSubscriber instance.
  - create
```
public static <T> TestSubscriber<T> create(long initialRequested)
```
    Creates a TestSubscriber with the given initial request.
    
    Type Parameters:
    T - the value type
    Parameters:
    initialRequested - the initial requested amount
    
    Returns:
    the new TestSubscriber instance.
  - create
```
public static <T> TestSubscriber<T> create(org.reactivestreams.Subscriber<? super T> delegate)
```
    Constructs a forwarding TestSubscriber.
    
    Type Parameters:
    T - the value type received
    Parameters:
    delegate - the actual Subscriber to forward events to
    
    Returns:
    the new TestObserver instance
  - onSubscribe
```
public void onSubscribe(org.reactivestreams.Subscription s)
```
    Specified by:
    
    onSubscribe in interface org.reactivestreams.Subscriber<T>
  - onStart
```
protected void onStart()
```
    Called after the onSubscribe is called and handled.
  - onNext
```
public void onNext(T t)
```
    Specified by:
    
    onNext in interface org.reactivestreams.Subscriber<T>
  - onError
```
public void onError(java.lang.Throwable t)
```
    Specified by:
    
    onError in interface org.reactivestreams.Subscriber<T>
  - onComplete
```
public void onComplete()
```
    Specified by:
    
    onComplete in interface org.reactivestreams.Subscriber<T>
  - request
```
public final void request(long n)
```
    Specified by:
    
    request in interface org.reactivestreams.Subscription
  - cancel
```
public final void cancel()
```
    Specified by:
    
    cancel in interface org.reactivestreams.Subscription
  - isCancelled
```
public final boolean isCancelled()
```
    Returns true if this TestSubscriber has been cancelled.
    
    Returns:
    true if this TestSubscriber has been cancelled
  - dispose
```
public final void dispose()
```
    Description copied from interface: Disposable
    
    Dispose the resource, the operation should be idempotent.
    
    Specified by:
    
    dispose in interface Disposable
  - isDisposed
```
public final boolean isDisposed()
```
    Description copied from interface: Disposable
    
    Returns true if this resource has been disposed.
    
    Specified by:
    
    isDisposed in interface Disposable
    
    Returns:
    true if this resource has been disposed
  - hasSubscription
```
public final boolean hasSubscription()
```
    Returns true if this TestSubscriber received a subscription.
    
    Returns:
    true if this TestSubscriber received a subscription
  - assertSubscribed
```
public final TestSubscriber<T> assertSubscribed()
```
    Assert that the onSubscribe method was called exactly once.
    
    Specified by:
    
    assertSubscribed in class BaseTestConsumer<T,TestSubscriber<T>>
    
    Returns:
    this
  - assertNotSubscribed
```
public final TestSubscriber<T> assertNotSubscribed()
```
    Assert that the onSubscribe method hasn't been called at all.
    
    Specified by:
    
    assertNotSubscribed in class BaseTestConsumer<T,TestSubscriber<T>>
    
    Returns:
    this
  - assertOf
```
public final TestSubscriber<T> assertOf(Consumer<? super TestSubscriber<T>> check)
```
    Run a check consumer with this TestSubscriber instance.
    
    Parameters:
    check - the check consumer to run
    
    Returns:
    this
  - requestMore
```
public final TestSubscriber<T> requestMore(long n)
```
    Calls request(long) and returns this.
    
    Parameters:
    n - the request amount
    
    Returns:
    this
    Since:
    
    2.0.1 - experimental

Class TestSubscriber<T>

Field Summary

Fields inherited from class io.reactivex.observers.BaseTestConsumer

Constructor Summary

Method Summary

Methods inherited from class io.reactivex.observers.BaseTestConsumer

Methods inherited from class java.lang.Object

Constructor Detail

TestSubscriber

TestSubscriber

TestSubscriber

TestSubscriber

Method Detail

create

create

create

onSubscribe

onStart

onNext

onError

onComplete

request

cancel

isCancelled

dispose

isDisposed

hasSubscription

assertSubscribed

assertNotSubscribed

assertOf

requestMore