public static class TestEnvironment.Receptacle<T> extends java.lang.Object
Modifier and Type | Method and Description |
---|---|
void |
add(T value) |
void |
complete() |
void |
expectCompletion(long timeoutMillis,
java.lang.String errorMsg) |
<E extends java.lang.Throwable> |
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) |
public void complete()
public T next(long timeoutMillis, java.lang.String errorMsg) throws java.lang.InterruptedException
java.lang.InterruptedException
public Optional<T> nextOrEndOfStream(long timeoutMillis, java.lang.String errorMsg) throws java.lang.InterruptedException
java.lang.InterruptedException
public java.util.List<T> nextN(long elements, long timeoutMillis, java.lang.String errorMsg) throws java.lang.InterruptedException
timeoutMillis
- total timeout time for awaiting all elements
number of elementsjava.lang.InterruptedException
public void expectCompletion(long timeoutMillis, java.lang.String errorMsg) throws java.lang.InterruptedException
java.lang.InterruptedException
public <E extends java.lang.Throwable> E expectError(java.lang.Class<E> clazz, long timeoutMillis, java.lang.String errorMsg) throws java.lang.Exception
java.lang.Exception
public void expectNone(long withinMillis, java.lang.String errorMsgPrefix) throws java.lang.InterruptedException
java.lang.InterruptedException