Class TestEnvironment.Promise<T>

java.lang.Object

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

Enclosing class:

TestEnvironment

public static class TestEnvironment.Promise<T>
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private AtomicReference<T>	_value
private ArrayBlockingQueue<T>	abq
private final TestEnvironment	env

Constructor Summary

Constructors

Constructor	Description
Promise(TestEnvironment env)

Method Summary

Modifier and Type	Method	Description
void	complete(T value)	Allows using expectCompletion to await for completion of the value and complete it _then_
static <T> TestEnvironment.Promise<T>	completed(TestEnvironment env, T value)
void	completeImmediatly(T value)	Same as complete.
void	expectCompletion(long timeoutMillis, String errorMsg)
boolean	isCompleted()
T	value()

Methods inherited from class Object

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

Field Details

env

private final TestEnvironment env

abq

private ArrayBlockingQueue<T> abq

_value

private AtomicReference<T> _value

Constructor Details

Promise

public Promise(TestEnvironment env)

Method Details

completed

public static <T> TestEnvironment.Promise<T> completed(TestEnvironment env,
 T value)

value

public T value()

isCompleted

public boolean isCompleted()

complete

public void complete(T value)

Allows using expectCompletion to await for completion of the value and complete it _then_

completeImmediatly

public void completeImmediatly(T value)

Same as complete. Keeping this method for binary compatibility.

expectCompletion

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

Throws:

InterruptedException