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, org.apache.maven.surefire.extensions.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 org.apache.maven.surefire.api.booter.Command	nextCommand()
org.apache.maven.surefire.api.booter.Command	readNextCommand()	Used by single thread in StreamFeeder class.

Methods inherited from class 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 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 org.apache.maven.surefire.api.booter.Command nextCommand()

readNextCommand

public org.apache.maven.surefire.api.booter.Command readNextCommand()
                                                             throws IOException

Used by single thread in StreamFeeder class.

Returns: