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 abstract boolean |
canContinue()
|
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, tryFlushavailable, close, mark, markSupported, read, read, reset, skipclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitnoop, provideNewTest, shutdown, skipSinceNextTestprotected abstract boolean isClosed()
protected abstract boolean canContinue()
protected void beforeNextCommand()
throws IOException
nextCommand()) unless the stream is atomically
closed (see isClosed() returns true) before this method has returned.IOExceptionprotected abstract Command nextCommand()
protected final void invalidateInternalBuffer()
protected final MasterProcessCommand getLastCommand()
public int read()
throws IOException
read in class InputStreamIOExceptionCopyright © 2004–2015 The Apache Software Foundation. All rights reserved.