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 and Description
Promise(TestEnvironment env)

Method Summary

Modifier and Type	Method and 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) Completes the promise right away, it is not possible to expectCompletion on a Promise completed this way
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)

Completes the promise right away, it is not possible to expectCompletion on a Promise completed this way

expectCompletion

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

Throws:

java.lang.InterruptedException