org.reactivestreams.tck

Class IdentityProcessorVerification.TestSetup

java.lang.Object

org.reactivestreams.tck.TestEnvironment.ManualPublisher<T>

org.reactivestreams.tck.IdentityProcessorVerification.TestSetup

All Implemented Interfaces:

org.reactivestreams.Publisher<T>

Enclosing class:

IdentityProcessorVerification<T>

public abstract class IdentityProcessorVerification.TestSetup
extends TestEnvironment.ManualPublisher<T>

Field Summary

Fields inherited from class org.reactivestreams.tck.TestEnvironment.ManualPublisher

cancelled, env, pendingDemand, requests, subscriber

Constructor Summary

Constructors

Constructor and Description
TestSetup(TestEnvironment env, int testBufferSize)

Method Summary

Modifier and Type	Method and Description
void	expectNextElement(TestEnvironment.ManualSubscriber<T> sub, T expected)
TestEnvironment.ManualSubscriber<T>	newSubscriber()
T	nextT()
T	sendNextTFromUpstream()

Methods inherited from class org.reactivestreams.tck.TestEnvironment.ManualPublisher

expectCancelling, expectCancelling, expectExactRequest, expectExactRequest, expectNoRequest, expectNoRequest, expectRequest, expectRequest, isCancelled, sendCompletion, sendError, sendNext, subscribe

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TestSetup

public TestSetup(TestEnvironment env,
                 int testBufferSize)
          throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

Method Detail

newSubscriber

public TestEnvironment.ManualSubscriber<T> newSubscriber()
                                                  throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

nextT

public T nextT()
        throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

expectNextElement

public void expectNextElement(TestEnvironment.ManualSubscriber<T> sub,
                              T expected)
                       throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

sendNextTFromUpstream

public T sendNextTFromUpstream()
                        throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException