org.reactivestreams.Subscriber<T>
, SubscriberWhiteboxVerification.SubscriberProbe<T>
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 | Description |
---|---|
BlackboxSubscriberProxy(TestEnvironment env,
org.reactivestreams.Subscriber<T> subscriber) |
Modifier and Type | Method | Description |
---|---|---|
void |
onComplete() |
|
void |
onError(java.lang.Throwable cause) |
|
void |
onNext(T t) |
|
void |
onSubscribe(org.reactivestreams.Subscription s) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
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>