public final class TestLessInputStream extends AbstractCommandStream
| Modifier and Type | Class and Description |
|---|---|
static class |
TestLessInputStream.TestLessInputStreamBuilder
Builds
streams, registers cachable commands
and provides accessible API to dispatch immediate commands to all atomically
alive streams. |
| Modifier and Type | Method and Description |
|---|---|
protected void |
beforeNextCommand()
Possibly waiting for next command (see
AbstractCommandStream.nextCommand()) unless the stream is atomically
closed (see AbstractCommandStream.isClosed() returns true) before this method has returned. |
protected boolean |
canContinue()
Unnecessarily opposite to
AbstractCommandStream.isClosed() however may respect
last command and AbstractCommandStream.isClosed(). |
void |
close() |
protected boolean |
isClosed() |
protected Command |
nextCommand() |
void |
noop() |
void |
provideNewTest()
Notifies
TestProvidingInputStream in order to dispatch a new test back to the forked
jvm (particular fork which hits this call); or do nothing in TestLessInputStream. |
void |
shutdown(Shutdown shutdownType) |
void |
skipSinceNextTest()
Sends an event to a fork jvm in order to skip tests.
|
getLastCommand, invalidateInternalBuffer, readsetFlushReceiverProvider, tryFlushavailable, mark, markSupported, read, read, reset, skippublic void provideNewTest()
NotifiableTestStreamTestProvidingInputStream in order to dispatch a new test back to the forked
jvm (particular fork which hits this call); or do nothing in TestLessInputStream.public void skipSinceNextTest()
NotifiableTestStreampublic void shutdown(Shutdown shutdownType)
public void noop()
protected boolean isClosed()
isClosed in class AbstractCommandStreamprotected boolean canContinue()
AbstractCommandStreamAbstractCommandStream.isClosed() however may respect
last command and AbstractCommandStream.isClosed().canContinue in class AbstractCommandStreamprotected Command nextCommand()
nextCommand in class AbstractCommandStreamprotected void beforeNextCommand()
throws IOException
AbstractCommandStreamAbstractCommandStream.nextCommand()) unless the stream is atomically
closed (see AbstractCommandStream.isClosed() returns true) before this method has returned.beforeNextCommand in class AbstractCommandStreamIOExceptionpublic void close()
close in interface Closeableclose in interface AutoCloseableclose in class InputStreamCopyright © 2004–2015 The Apache Software Foundation. All rights reserved.