Class AbstractCommandStream
java.lang.Object
java.io.InputStream
org.apache.maven.plugin.surefire.booterclient.lazytestprovider.AbstractForkInputStream
org.apache.maven.plugin.surefire.booterclient.lazytestprovider.AbstractCommandStream
- All Implemented Interfaces:
Closeable
,AutoCloseable
,NotifiableTestStream
- Direct Known Subclasses:
TestLessInputStream
,TestProvidingInputStream
Reader stream sends commands to forked jvm std-
input-stream
.- Since:
- 2.19
- See Also:
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected void
Possibly waiting for next command (seenextCommand()
) unless the stream is atomically closed (seeisClosed()
returnstrue
) before this method has returned.protected boolean
Opposite toisClosed()
.protected final void
Returns quietly and immediately.protected abstract boolean
isClosed()
protected abstract Command
int
read()
Used by single thread in StreamFeeder class.Methods inherited from class org.apache.maven.plugin.surefire.booterclient.lazytestprovider.AbstractForkInputStream
setFlushReceiverProvider, tryFlush
Methods inherited from class java.io.InputStream
available, close, mark, markSupported, nullInputStream, read, read, readAllBytes, readNBytes, readNBytes, reset, skip, skipNBytes, transferTo
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.apache.maven.plugin.surefire.booterclient.lazytestprovider.NotifiableTestStream
acknowledgeByeEventReceived, noop, provideNewTest, shutdown, skipSinceNextTest
-
Field Details
-
currentBuffer
private byte[] currentBuffer -
currentPos
private int currentPos
-
-
Constructor Details
-
AbstractCommandStream
public AbstractCommandStream()
-
-
Method Details
-
isClosed
protected abstract boolean isClosed() -
canContinue
protected boolean canContinue()Opposite toisClosed()
.- Returns:
true
if not closed
-
beforeNextCommand
Possibly waiting for next command (seenextCommand()
) unless the stream is atomically closed (seeisClosed()
returnstrue
) before this method has returned.- Throws:
IOException
- stream error while waiting for notification regarding next test required by forked jvm
-
nextCommand
-
invalidateInternalBuffer
protected final void invalidateInternalBuffer()Returns quietly and immediately. -
read
Used by single thread in StreamFeeder class.- Specified by:
read
in classInputStream
- Returns:
- Throws:
IOException
-