Package org.reactivestreams.tck
Class IdentityProcessorVerification.TestSetup
java.lang.Object
org.reactivestreams.tck.TestEnvironment.ManualPublisher<T>
org.reactivestreams.tck.IdentityProcessorVerification.TestSetup
- All Implemented Interfaces:
Publisher<T>
- Enclosing class:
IdentityProcessorVerification<T>
public abstract class IdentityProcessorVerification.TestSetup
extends TestEnvironment.ManualPublisher<T>
-
Field Summary
FieldsFields inherited from class org.reactivestreams.tck.TestEnvironment.ManualPublisher
cancelled, env, pendingDemand, requests, subscriber
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
expectNextElement
(TestEnvironment.ManualSubscriber<T> sub, T expected) void
expectNextElement
(TestEnvironment.ManualSubscriber<T> sub, T expected, String errorMessageAddendum) nextT()
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
-
tees
-
seenTees
-
processor
-
-
Constructor Details
-
TestSetup
- Throws:
InterruptedException
-
-
Method Details
-
newSubscriber
- Throws:
InterruptedException
-
nextT
- Throws:
InterruptedException
-
expectNextElement
public void expectNextElement(TestEnvironment.ManualSubscriber<T> sub, T expected) throws InterruptedException - Throws:
InterruptedException
-
expectNextElement
public void expectNextElement(TestEnvironment.ManualSubscriber<T> sub, T expected, String errorMessageAddendum) throws InterruptedException - Throws:
InterruptedException
-
sendNextTFromUpstream
- Throws:
InterruptedException
-