public abstract class AbstractCommandStream extends AbstractForkInputStream
input-stream
.Command
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 MasterProcessCommand |
getLastCommand() |
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()
.protected void beforeNextCommand() throws IOException
nextCommand()
) unless the stream is atomically
closed (see isClosed()
returns true
) before this method has returned.IOException
protected abstract Command nextCommand()
protected final void invalidateInternalBuffer()
protected final MasterProcessCommand getLastCommand()
public int read() throws IOException
read
in class InputStream
IOException
Copyright © 2004–2017 The Apache Software Foundation. All rights reserved.