Package org.reactivestreams.tck
Class SubscriberWhiteboxVerification.WhiteboxTestStage
java.lang.Object
org.reactivestreams.tck.TestEnvironment.ManualPublisher<T>
org.reactivestreams.tck.SubscriberWhiteboxVerification.WhiteboxTestStage
- All Implemented Interfaces:
Publisher<T>
- Enclosing class:
SubscriberWhiteboxVerification<T>
public class SubscriberWhiteboxVerification.WhiteboxTestStage
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 TypeMethodDescriptioncreateHelperPublisher
(long elements) nextT()
probe()
puppet()
private T
signalNext
(T element) Subscriber
<? super T> sub()
void
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
-
probe
-
lastT
-
-
Constructor Details
-
WhiteboxTestStage
- Throws:
InterruptedException
-
WhiteboxTestStage
- Throws:
InterruptedException
-
-
Method Details
-
sub
-
puppet
-
probe
-
createHelperPublisher
-
createWhiteboxSubscriberProbe
public SubscriberWhiteboxVerification.WhiteboxSubscriberProbe<T> createWhiteboxSubscriberProbe(TestEnvironment env) -
signalNext
- Throws:
InterruptedException
-
signalNext
- Throws:
InterruptedException
-
nextT
- Throws:
InterruptedException
-
verifyNoAsyncErrors
public void verifyNoAsyncErrors()
-