Class TestEnvironment.Receptacle<T>

java.lang.Object

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

Enclosing class:

TestEnvironment

public static class TestEnvironment.Receptacle<T>
extends Object

Method Summary

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

Methods inherited from class Object

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

Method Details

add

public void add(T value)

complete

public void complete()

next

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

Throws:

InterruptedException

nextOrEndOfStream

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

Throws:

InterruptedException

nextN

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

Parameters:

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

Throws:

InterruptedException

expectCompletion

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

Throws:

InterruptedException

expectError

@Deprecated
public <E extends Throwable> E expectError(Class<E> clazz,
 long timeoutMillis,
 String errorMsg)
                                    throws Exception

Deprecated.

Deprecated in favor of expectError(Class, long, long, String).

Throws:

Exception

expectNone

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

Throws:

InterruptedException