Class DefaultCommandReader
- java.lang.Object
-
- org.apache.maven.plugin.surefire.booterclient.lazytestprovider.AbstractCommandReader
-
- org.apache.maven.plugin.surefire.booterclient.lazytestprovider.DefaultCommandReader
-
- All Implemented Interfaces:
java.io.Closeable
,java.lang.AutoCloseable
,NotifiableTestStream
,CommandReader
- Direct Known Subclasses:
TestLessInputStream
,TestProvidingInputStream
public abstract class DefaultCommandReader extends AbstractCommandReader
Reader stream sends commands to forked jvm std-input-stream
.- Since:
- 2.19
- See Also:
Command
-
-
Constructor Summary
Constructors Constructor Description DefaultCommandReader()
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description protected void
beforeNextCommand()
Possibly waiting for next command (seenextCommand()
) unless the stream is atomically closed (seeCommandReader.isClosed()
returnstrue
) before this method has returned.protected boolean
canContinue()
Opposite toCommandReader.isClosed()
.protected abstract Command
nextCommand()
Command
readNextCommand()
Used by single thread in StreamFeeder class.-
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.surefire.extensions.CommandReader
close, isClosed
-
Methods inherited from interface org.apache.maven.plugin.surefire.booterclient.lazytestprovider.NotifiableTestStream
acknowledgeByeEventReceived, noop, provideNewTest, shutdown, skipSinceNextTest
-
-
-
-
Method Detail
-
canContinue
protected boolean canContinue()
Opposite toCommandReader.isClosed()
.- Returns:
true
if not closed
-
beforeNextCommand
protected void beforeNextCommand() throws java.io.IOException
Possibly waiting for next command (seenextCommand()
) unless the stream is atomically closed (seeCommandReader.isClosed()
returnstrue
) before this method has returned.- Throws:
java.io.IOException
- stream error while waiting for notification regarding next test required by forked jvm
-
nextCommand
protected abstract Command nextCommand()
-
readNextCommand
public Command readNextCommand() throws java.io.IOException
Used by single thread in StreamFeeder class.- Returns:
- the command, or null if closed
- Throws:
java.io.IOException
-
-