Package org.reactivestreams.tck
Class SubscriberBlackboxVerification.BlackboxTestStage
- java.lang.Object
-
- org.reactivestreams.tck.TestEnvironment.ManualPublisher<T>
-
- org.reactivestreams.tck.SubscriberBlackboxVerification.BlackboxTestStage
-
- All Implemented Interfaces:
Publisher<T>
- Enclosing class:
- SubscriberBlackboxVerification<T>
public class SubscriberBlackboxVerification.BlackboxTestStage extends TestEnvironment.ManualPublisher<T>
-
-
Field Summary
Fields Modifier and Type Field Description T
lastT
Publisher<T>
pub
private Optional<SubscriberWhiteboxVerification.BlackboxSubscriberProxy<T>>
subProxy
TestEnvironment.ManualSubscriber<T>
tees
-
Fields inherited from class org.reactivestreams.tck.TestEnvironment.ManualPublisher
cancelled, env, pendingDemand, requests, subscriber
-
-
Constructor Summary
Constructors Constructor Description BlackboxTestStage(TestEnvironment env)
BlackboxTestStage(TestEnvironment env, boolean runDefaultInit)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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 thesub()
Subscriber
, providing certain assertions on methods being called on the Subscriber.-
Methods inherited from class org.reactivestreams.tck.TestEnvironment.ManualPublisher
expectCancelling, expectCancelling, expectExactRequest, expectExactRequest, expectNoRequest, expectNoRequest, expectRequest, expectRequest, expectRequest, isCancelled, sendCompletion, sendError, sendNext, subscribe
-
-
-
-
Field Detail
-
tees
public TestEnvironment.ManualSubscriber<T> tees
-
lastT
public T lastT
-
subProxy
private Optional<SubscriberWhiteboxVerification.BlackboxSubscriberProxy<T>> subProxy
-
-
Constructor Detail
-
BlackboxTestStage
public BlackboxTestStage(TestEnvironment env) throws java.lang.InterruptedException
- Throws:
java.lang.InterruptedException
-
BlackboxTestStage
public BlackboxTestStage(TestEnvironment env, boolean runDefaultInit) throws java.lang.InterruptedException
- Throws:
java.lang.InterruptedException
-
-
Method Detail
-
sub
public Subscriber<? super T> sub()
-
subProxy
public SubscriberWhiteboxVerification.BlackboxSubscriberProxy<T> subProxy()
Proxy for thesub()
Subscriber
, providing certain assertions on methods being called on the Subscriber.
-
createBlackboxSubscriberProxy
public SubscriberWhiteboxVerification.BlackboxSubscriberProxy<T> createBlackboxSubscriberProxy(TestEnvironment env, Subscriber<T> sub)
-
signalNext
public T signalNext() throws java.lang.InterruptedException
- Throws:
java.lang.InterruptedException
-
nextT
public T nextT() throws java.lang.InterruptedException
- Throws:
java.lang.InterruptedException
-
-