Class TestEnvironment.Latch

java.lang.Object

org.reactivestreams.tck.TestEnvironment.Latch

Enclosing class:

TestEnvironment

public static class TestEnvironment.Latch
extends Object

Like a CountDownLatch, but resettable and with some convenience methods

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static final class	TestEnvironment.Latch.ExpectedClosedLatchException
(package private) static final class	TestEnvironment.Latch.ExpectedOpenLatchException

Field Summary

Fields

Modifier and Type	Field	Description
private CountDownLatch	countDownLatch
private final TestEnvironment	env

Constructor Summary

Constructors

Constructor	Description
Latch(TestEnvironment env)

Method Summary

Modifier and Type	Method	Description
void	assertClosed(String openErrorMsg)
void	assertOpen(String closedErrorMsg)
void	close()
void	expectClose(long timeoutMillis, String notClosedErrorMsg)
void	expectClose(String notClosedErrorMsg)
boolean	isClosed()
void	reOpen()

Methods inherited from class Object

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

Field Details

env

private final TestEnvironment env

countDownLatch

private volatile CountDownLatch countDownLatch

Constructor Details

Latch

public Latch(TestEnvironment env)

Method Details

reOpen

public void reOpen()

isClosed

public boolean isClosed()

close

public void close()

assertClosed

public void assertClosed(String openErrorMsg)

assertOpen

public void assertOpen(String closedErrorMsg)

expectClose

public void expectClose(String notClosedErrorMsg)
                 throws InterruptedException

Throws:

InterruptedException

expectClose

public void expectClose(long timeoutMillis,
 String notClosedErrorMsg)
                 throws InterruptedException

Throws:

InterruptedException