Package org.reactivestreams.tck
Class TestEnvironment.Promise<T>
java.lang.Object
org.reactivestreams.tck.TestEnvironment.Promise<T>
- Enclosing class:
TestEnvironment
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate AtomicReference
<T> private ArrayBlockingQueue
<T> private final TestEnvironment
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
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
value()
-
Field Details
-
env
-
abq
-
_value
-
-
Constructor Details
-
Promise
-
-
Method Details
-
completed
-
value
-
isCompleted
public boolean isCompleted() -
complete
Allows using expectCompletion to await for completion of the value and complete it _then_ -
completeImmediatly
Same as complete. Keeping this method for binary compatibility. -
expectCompletion
- Throws:
InterruptedException
-