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
FieldsModifier and TypeFieldDescriptionFields inherited from class org.reactivestreams.tck.TestEnvironment.ManualPublisher
cancelled, env, pendingDemand, requests, subscriber
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptioncreateBlackboxSubscriberProxy
(TestEnvironment env, Subscriber<T> sub) createHelperPublisher
(long elements) nextT()
Subscriber
<? super T> sub()
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 Details
-
pub
-
tees
-
lastT
-
subProxy
-
-
Constructor Details
-
BlackboxTestStage
- Throws:
InterruptedException
-
BlackboxTestStage
- Throws:
InterruptedException
-
-
Method Details
-
sub
-
subProxy
Proxy for thesub()
Subscriber
, providing certain assertions on methods being called on the Subscriber. -
createHelperPublisher
-
createBlackboxSubscriberProxy
public SubscriberWhiteboxVerification.BlackboxSubscriberProxy<T> createBlackboxSubscriberProxy(TestEnvironment env, Subscriber<T> sub) -
signalNext
- Throws:
InterruptedException
-
nextT
- Throws:
InterruptedException
-