Package org.apache.maven.plugin.surefire.booterclient.lazytestprovider

Class DefaultCommandReader

java.lang.Object

org.apache.maven.plugin.surefire.booterclient.lazytestprovider.AbstractCommandReader

org.apache.maven.plugin.surefire.booterclient.lazytestprovider.DefaultCommandReader

All Implemented Interfaces:

Closeable, 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

Author:

Tibor Digana (tibor17)

See Also:

• Command

Constructor Summary

Constructors

Constructor	Description
DefaultCommandReader()

Method Summary

Modifier and Type	Method	Description
protected void	beforeNextCommand()	Possibly waiting for next command (see nextCommand()) unless the stream is atomically closed (see CommandReader.isClosed() returns true) before this method has returned.
protected boolean	canContinue()	Opposite to CommandReader.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

Constructor Details

DefaultCommandReader

public DefaultCommandReader()

Method Details

canContinue

protected boolean canContinue()

Opposite to CommandReader.isClosed().

Returns:

true if not closed

beforeNextCommand

protected void beforeNextCommand()
                          throws IOException

Possibly waiting for next command (see nextCommand()) unless the stream is atomically closed (see CommandReader.isClosed() returns true) before this method has returned.

Throws:

IOException - stream error while waiting for notification regarding next test required by forked jvm

nextCommand

protected abstract Command nextCommand()

readNextCommand

public Command readNextCommand()
                        throws IOException

Used by single thread in StreamFeeder class.

Returns:

Throws:

IOException