Package org.reactivestreams.tck

Class IdentityProcessorVerification.TestSetup

java.lang.Object

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

org.reactivestreams.tck.IdentityProcessorVerification.TestSetup

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	Description
TestSetup(TestEnvironment env, int testBufferSize)

Method Summary

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

Methods inherited from class java.lang.Object

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

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

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

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

expectNextElement

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

Throws:

java.lang.InterruptedException

sendNextTFromUpstream

public T sendNextTFromUpstream()
                        throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException