Package org.reactivestreams.tck

Class TestEnvironment.Receptacle<T>

java.lang.Object

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

Enclosing class:

TestEnvironment

public static class TestEnvironment.Receptacle<T>
extends java.lang.Object

Method Summary

Modifier and Type	Method	Description
void	add(T value)
void	complete()
void	expectCompletion(long timeoutMillis, java.lang.String errorMsg)
<E extends java.lang.Throwable> E	expectError(java.lang.Class<E> clazz, long timeoutMillis, java.lang.String errorMsg)
void	expectNone(long withinMillis, java.lang.String errorMsgPrefix)
T	next(long timeoutMillis, java.lang.String errorMsg)
java.util.List<T>	nextN(long elements, long timeoutMillis, java.lang.String errorMsg)
Optional<T>	nextOrEndOfStream(long timeoutMillis, java.lang.String errorMsg)

Methods inherited from class java.lang.Object

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

Method Detail

add

public void add(T value)

complete

public void complete()

next

public T next(long timeoutMillis,
              java.lang.String errorMsg)
       throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

nextOrEndOfStream

public Optional<T> nextOrEndOfStream(long timeoutMillis,
                                     java.lang.String errorMsg)
                              throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

nextN

public java.util.List<T> nextN(long elements,
                               long timeoutMillis,
                               java.lang.String errorMsg)
                        throws java.lang.InterruptedException

Parameters:

timeoutMillis - total timeout time for awaiting all elements number of elements

Throws:

java.lang.InterruptedException

expectCompletion

public void expectCompletion(long timeoutMillis,
                             java.lang.String errorMsg)
                      throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

expectError

public <E extends java.lang.Throwable> E expectError(java.lang.Class<E> clazz,
                                                     long timeoutMillis,
                                                     java.lang.String errorMsg)
                                              throws java.lang.Exception

Throws:

java.lang.Exception

expectNone

public void expectNone(long withinMillis,
                       java.lang.String errorMsgPrefix)
                throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException