public static class TestEnvironment.ManualSubscriberWithSubscriptionSupport<T> extends TestEnvironment.ManualSubscriber<T>
env
Constructor and Description |
---|
ManualSubscriberWithSubscriptionSupport(TestEnvironment env) |
Modifier and Type | Method and Description |
---|---|
void |
onComplete()
Successful terminal state.
|
void |
onError(java.lang.Throwable cause)
Failed terminal state.
|
void |
onNext(T element)
Data notification sent by the
Publisher in response to requests to Subscription.request(long) . |
void |
onSubscribe(Subscription s)
Invoked after calling
Publisher.subscribe(Subscriber) . |
expectCompletion, expectCompletion, expectCompletion, expectCompletion, expectError, expectError, expectError, expectError, expectErrorWithMessage, expectErrorWithMessage, expectNext, expectNext, expectNone, expectNone, expectNone, expectNone, nextElement, nextElement, nextElement, nextElement, nextElementOrEndOfStream, nextElementOrEndOfStream, nextElementOrEndOfStream, nextElements, nextElements, nextElements, nextElements, request, requestEndOfStream, requestEndOfStream, requestEndOfStream, requestEndOfStream, requestNextElement, requestNextElement, requestNextElement, requestNextElement, requestNextElementOrEndOfStream, requestNextElementOrEndOfStream, requestNextElementOrEndOfStream, requestNextElements, requestNextElements, requestNextElements
cancel
public ManualSubscriberWithSubscriptionSupport(TestEnvironment env)
public void onNext(T element)
Subscriber
Publisher
in response to requests to Subscription.request(long)
.onNext
in interface Subscriber<T>
onNext
in class TestEnvironment.ManualSubscriber<T>
element
- the element signaledpublic void onComplete()
Subscriber
No further events will be sent even if Subscription.request(long)
is invoked again.
onComplete
in interface Subscriber<T>
onComplete
in class TestEnvironment.ManualSubscriber<T>
public void onSubscribe(Subscription s)
Subscriber
Publisher.subscribe(Subscriber)
.
No data will start flowing until Subscription.request(long)
is invoked.
It is the responsibility of this Subscriber
instance to call Subscription.request(long)
whenever more data is wanted.
The Publisher
will send notifications only in response to Subscription.request(long)
.
onSubscribe
in interface Subscriber<T>
onSubscribe
in class TestEnvironment.TestSubscriber<T>
s
- Subscription
that allows requesting data via Subscription.request(long)
public void onError(java.lang.Throwable cause)
Subscriber
No further events will be sent even if Subscription.request(long)
is invoked again.
onError
in interface Subscriber<T>
onError
in class TestEnvironment.TestSubscriber<T>
cause
- the throwable signaled