Package 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	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 org.reactivestreams.tck.TestEnvironment.ManualPublisher

expectCancelling, expectCancelling, expectExactRequest, expectExactRequest, expectNoRequest, expectNoRequest, expectRequest, 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

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