Class TestEnvironment.Receptacle<T>

java.lang.Object

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

Enclosing class:

TestEnvironment

public static class TestEnvironment.Receptacle<T>
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private final ArrayBlockingQueue<Optional<T>>	abq
private final TestEnvironment.Latch	completedLatch
private final TestEnvironment	env
(package private) final int	QUEUE_SIZE

Constructor Summary

Constructors

Constructor	Description
Receptacle(TestEnvironment env)

Method Summary

Modifier and Type	Method	Description
void	add(T value)
void	complete()
void	expectCompletion(long timeoutMillis, String errorMsg)
(package private) final <E extends Throwable> E	expectError(Class<E> clazz, long totalTimeoutMillis, long pollTimeoutMillis, 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

Field Details

QUEUE_SIZE

final int QUEUE_SIZE

See Also:

• Constant Field Values

env

private final TestEnvironment env

abq

private final ArrayBlockingQueue<Optional<T>> abq

completedLatch

private final TestEnvironment.Latch completedLatch

Constructor Details

Receptacle

Receptacle(TestEnvironment env)

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

expectError

final <E extends Throwable> E expectError(Class<E> clazz,
 long totalTimeoutMillis,
 long pollTimeoutMillis,
 String errorMsg)
                                   throws Exception

Throws:

Exception

expectNone

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

Throws:

InterruptedException