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, tryFlush
available, close, mark, markSupported, read, read, reset, skip
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
noop, provideNewTest, shutdown, skipSinceNextTest
protected 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.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–2015 The Apache Software Foundation. All rights reserved.