T - the value typepublic class TestSubscriber<T> extends BaseTestConsumer<T,TestSubscriber<T>> implements FlowableSubscriber<T>, Subscription, Disposable
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.
BaseTestConsumer.TestWaitStrategy checkSubscriptionOnce, completions, done, errors, establishedFusionMode, initialFusionMode, lastThread, tag, timeout, values | 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 (Subscriber<? super T> downstream)
Constructs a forwarding TestSubscriber but leaves the requesting to the wrapped subscriber.
|
TestSubscriber (Subscriber<? super T> actual,
long initialRequest)
Constructs a forwarding TestSubscriber with the specified initial request value.
|
| 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 (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 (Throwable t) |
void |
onNext (T t) |
protected void |
onStart ()
Called after the onSubscribe is called and handled.
|
void |
onSubscribe (Subscription s)
Implementors of this method should make sure everything that needs
to be visible in
Subscriber.onNext(Object) is established before
calling Subscription.request(long). |
void |
request (long n) |
TestSubscriber<T> |
requestMore (long n)
Calls
request(long) and returns this. |
assertComplete, assertEmpty, assertError, assertError, assertError, assertErrorMessage, assertFailure, assertFailure, assertFailureAndMessage, assertNever, assertNever, assertNoErrors, assertNotComplete, assertNoTimeout, assertNotTerminated, assertNoValues, assertResult, assertTerminated, assertTimeout, assertValue, assertValue, assertValueAt, assertValueAt, assertValueCount, assertValues, assertValueSequence, assertValueSequenceOnly, assertValueSet, assertValueSetOnly, assertValuesOnly, await, await, awaitCount, awaitCount, awaitCount, awaitDone, awaitTerminalEvent, awaitTerminalEvent, clearTimeout, completions, errorCount, errors, fail, getEvents, isTerminated, isTimeout, lastThread, valueAndClass, valueCount, values, withTag public TestSubscriber()
public TestSubscriber(long initialRequest)
The TestSubscriber doesn't validate the initialRequest value so one can test sources with invalid values as well.
initialRequest - the initial request valuepublic TestSubscriber(Subscriber<? super T> downstream)
downstream - the actual Subscriber to forward events topublic TestSubscriber(Subscriber<? super T> actual, long initialRequest)
The TestSubscriber doesn't validate the initialRequest value so one can test sources with invalid values as well.
actual - the actual Subscriber to forward events toinitialRequest - the initial request valuepublic static <T> TestSubscriber<T> create()
T - the value typepublic static <T> TestSubscriber<T> create(long initialRequested)
T - the value typeinitialRequested - the initial requested amountpublic static <T> TestSubscriber<T> create(Subscriber<? super T> delegate)
T - the value type receiveddelegate - the actual Subscriber to forward events topublic void onSubscribe(Subscription s)
FlowableSubscriber Subscriber.onNext(Object) is established before
calling Subscription.request(long). In practice this means
no initialization should happen after the request() call and
additional behavior is thread safe in respect to onNext.
onSubscribe in interface FlowableSubscriber<T>onSubscribe in interface Subscriber<T>protected void onStart()
public void onNext(T t)
onNext in interface Subscriber<T>public void onError(Throwable t)
onError in interface Subscriber<T>public void onComplete()
onComplete in interface Subscriber<T>public final void request(long n)
request in interface Subscription public final void cancel()
cancel in interface Subscription public final boolean isCancelled()
public final void dispose()
Disposable dispose in interface Disposable public final boolean isDisposed()
Disposable isDisposed in interface Disposable public final boolean hasSubscription()
public final TestSubscriber<T> assertSubscribed()
assertSubscribed in class BaseTestConsumer<T,TestSubscriber<T>>public final TestSubscriber<T> assertNotSubscribed()
assertNotSubscribed in class BaseTestConsumer<T,TestSubscriber<T>>public final TestSubscriber<T> assertOf(Consumer<? super TestSubscriber<T>> check)
check - the check consumer to runpublic final TestSubscriber<T> requestMore(long n)
request(long) and returns this.
History: 2.0.1 - experimental
n - the request amount