Package org.reactivestreams.tck
Class TestEnvironment.Latch
java.lang.Object
org.reactivestreams.tck.TestEnvironment.Latch
- Enclosing class:
TestEnvironment
Like a CountDownLatch, but resettable and with some convenience methods
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescription(package private) static final class
(package private) static final class
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
assertClosed
(String openErrorMsg) void
assertOpen
(String closedErrorMsg) void
close()
void
expectClose
(long timeoutMillis, String notClosedErrorMsg) void
expectClose
(String notClosedErrorMsg) boolean
isClosed()
void
reOpen()
-
Field Details
-
env
-
countDownLatch
-
-
Constructor Details
-
Latch
-
-
Method Details
-
reOpen
public void reOpen() -
isClosed
public boolean isClosed() -
close
public void close() -
assertClosed
-
assertOpen
-
expectClose
- Throws:
InterruptedException
-
expectClose
- Throws:
InterruptedException
-