org.reactivestreams.tck

Class TestEnvironment

java.lang.Object

org.reactivestreams.tck.TestEnvironment

public class TestEnvironment
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
static int	TEST_BUFFER_SIZE

Constructor Summary

Constructors

Constructor and Description
TestEnvironment(long defaultTimeoutMillis) Tests must specify the timeout for expected outcome of asynchronous interactions.

Method Summary

Modifier and Type	Method and Description
long	defaultTimeoutMillis()
<T extends java.lang.Throwable> void	expectThrowingOf(java.lang.Class<T> clazz, java.lang.String errorMsg, java.lang.Runnable block)
void	flop(java.lang.String msg)
<T> org.reactivestreams.tck.TestEnvironment.ManualSubscriber<T>	newManualSubscriber(org.reactivestreams.spi.Publisher<T> pub)
<T> org.reactivestreams.tck.TestEnvironment.ManualSubscriber<T>	newManualSubscriber(org.reactivestreams.spi.Publisher<T> pub, long timeoutMillis)
<T> void	subscribe(org.reactivestreams.spi.Publisher<T> pub, org.reactivestreams.tck.TestEnvironment.TestSubscriber<T> sub)
<T> void	subscribe(org.reactivestreams.spi.Publisher<T> pub, org.reactivestreams.tck.TestEnvironment.TestSubscriber<T> sub, long timeoutMillis)
void	verifyNoAsyncErrors()

Methods inherited from class java.lang.Object

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

Field Detail

TEST_BUFFER_SIZE

public static final int TEST_BUFFER_SIZE

See Also:

Constant Field Values

Constructor Detail

TestEnvironment

public TestEnvironment(long defaultTimeoutMillis)

Tests must specify the timeout for expected outcome of asynchronous interactions. Longer timeout does not invalidate the correctness of the implementation, but can in some cases result in longer time to run the tests.

Method Detail

defaultTimeoutMillis

public long defaultTimeoutMillis()

flop

public void flop(java.lang.String msg)

expectThrowingOf

public <T extends java.lang.Throwable> void expectThrowingOf(java.lang.Class<T> clazz,
                                                             java.lang.String errorMsg,
                                                             java.lang.Runnable block)
                                                      throws java.lang.Throwable

Throws:

java.lang.Throwable

subscribe

public <T> void subscribe(org.reactivestreams.spi.Publisher<T> pub,
                          org.reactivestreams.tck.TestEnvironment.TestSubscriber<T> sub)
                   throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

subscribe

public <T> void subscribe(org.reactivestreams.spi.Publisher<T> pub,
                          org.reactivestreams.tck.TestEnvironment.TestSubscriber<T> sub,
                          long timeoutMillis)
                   throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

newManualSubscriber

public <T> org.reactivestreams.tck.TestEnvironment.ManualSubscriber<T> newManualSubscriber(org.reactivestreams.spi.Publisher<T> pub)
                                                                                    throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

newManualSubscriber

public <T> org.reactivestreams.tck.TestEnvironment.ManualSubscriber<T> newManualSubscriber(org.reactivestreams.spi.Publisher<T> pub,
                                                                                           long timeoutMillis)
                                                                                    throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

verifyNoAsyncErrors

public void verifyNoAsyncErrors()