public static class SubscriberWhiteboxVerification.BlackboxSubscriberProxy<T> extends SubscriberWhiteboxVerification.BlackboxProbe<T> implements org.reactivestreams.Subscriber<T>
Subscriber
decorator and should be used in pub.subscriber(...)
calls,
in order to allow intercepting calls on the underlying Subscriber
.
This delegation allows the proxy to implement SubscriberWhiteboxVerification.BlackboxProbe
assertions.elements, env, error, subscriber
Constructor and Description |
---|
BlackboxSubscriberProxy(TestEnvironment env,
org.reactivestreams.Subscriber<T> subscriber) |
Modifier and Type | Method and Description |
---|---|
void |
onComplete() |
void |
onError(java.lang.Throwable cause) |
void |
onNext(T t) |
void |
onSubscribe(org.reactivestreams.Subscription s) |
expectCompletion, expectCompletion, expectCompletion, expectError, expectError, expectError, expectError, expectErrorWithMessage, expectNext, expectNext, expectNext, expectNone, expectNone, registerOnComplete, registerOnError, registerOnNext, sub
public BlackboxSubscriberProxy(TestEnvironment env, org.reactivestreams.Subscriber<T> subscriber)
public void onSubscribe(org.reactivestreams.Subscription s)
onSubscribe
in interface org.reactivestreams.Subscriber<T>
public void onError(java.lang.Throwable cause)
onError
in interface org.reactivestreams.Subscriber<T>
public void onComplete()
onComplete
in interface org.reactivestreams.Subscriber<T>