public abstract class AbstractCommandStream extends AbstractForkInputStream
input-stream
.Command
Modifier and Type | Field and Description |
---|---|
private byte[] |
currentBuffer |
private int |
currentPos |
Constructor and Description |
---|
AbstractCommandStream() |
Modifier and Type | Method and Description |
---|---|
protected void |
beforeNextCommand()
Possibly waiting for next command (see
nextCommand() ) unless the stream is atomically
closed (see isClosed() returns true ) before this method has returned. |
protected boolean |
canContinue()
Opposite to
isClosed() . |
protected void |
invalidateInternalBuffer()
Returns quietly and immediately.
|
protected abstract boolean |
isClosed() |
protected abstract Command |
nextCommand() |
int |
read()
Used by single thread in StreamFeeder class.
|
setFlushReceiverProvider, tryFlush
available, close, mark, markSupported, read, read, reset, skip
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
acknowledgeByeEventReceived, noop, provideNewTest, shutdown, skipSinceNextTest
protected abstract boolean isClosed()
protected boolean canContinue()
isClosed()
.true
if not closedprotected void beforeNextCommand() throws java.io.IOException
nextCommand()
) unless the stream is atomically
closed (see isClosed()
returns true
) before this method has returned.java.io.IOException
- stream error while waiting for notification regarding next test required by forked jvmprotected abstract Command nextCommand()
protected final void invalidateInternalBuffer()
public int read() throws java.io.IOException
read
in class java.io.InputStream
java.io.IOException