Package org.reactivestreams.tck

Class TestEnvironment.Promise<T>

java.lang.Object

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

Enclosing class:

TestEnvironment

public static class TestEnvironment.Promise<T>
extends java.lang.Object

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, java.lang.String errorMsg)
boolean	isCompleted()
T	value()

Methods inherited from class java.lang.Object

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

Constructor Detail

Promise

public Promise(TestEnvironment env)

Method Detail

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,
                             java.lang.String errorMsg)
                      throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException