public class SubscriberBlackboxVerification.BlackboxTestStage extends TestEnvironment.ManualPublisher<T>
Modifier and Type | Field | Description |
---|---|---|
T |
lastT |
|
org.reactivestreams.Publisher<T> |
pub |
|
TestEnvironment.ManualSubscriber<T> |
tees |
cancelled, env, pendingDemand, requests, subscriber
Constructor | Description |
---|---|
BlackboxTestStage(TestEnvironment env) |
|
BlackboxTestStage(TestEnvironment env,
boolean runDefaultInit) |
Modifier and Type | Method | Description |
---|---|---|
SubscriberWhiteboxVerification.BlackboxSubscriberProxy<T> |
createBlackboxSubscriberProxy(TestEnvironment env,
org.reactivestreams.Subscriber<T> sub) |
|
org.reactivestreams.Publisher<T> |
createHelperPublisher(long elements) |
|
T |
nextT() |
|
T |
signalNext() |
|
org.reactivestreams.Subscriber<? super T> |
sub() |
|
SubscriberWhiteboxVerification.BlackboxSubscriberProxy<T> |
subProxy() |
Proxy for the
sub() Subscriber , providing certain assertions on methods being called on the Subscriber. |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
expectCancelling, expectCancelling, expectExactRequest, expectExactRequest, expectNoRequest, expectNoRequest, expectRequest, expectRequest, expectRequest, isCancelled, sendCompletion, sendError, sendNext, subscribe
public TestEnvironment.ManualSubscriber<T> tees
public BlackboxTestStage(TestEnvironment env) throws java.lang.InterruptedException
java.lang.InterruptedException
public BlackboxTestStage(TestEnvironment env, boolean runDefaultInit) throws java.lang.InterruptedException
java.lang.InterruptedException
public SubscriberWhiteboxVerification.BlackboxSubscriberProxy<T> subProxy()
sub()
Subscriber
, providing certain assertions on methods being called on the Subscriber.public org.reactivestreams.Publisher<T> createHelperPublisher(long elements)
public SubscriberWhiteboxVerification.BlackboxSubscriberProxy<T> createBlackboxSubscriberProxy(TestEnvironment env, org.reactivestreams.Subscriber<T> sub)
public T signalNext() throws java.lang.InterruptedException
java.lang.InterruptedException