public static class TestEnvironment.Receptacle<T> extends java.lang.Object
Modifier and Type | Method | 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