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