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

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

public abstract class AbstractCommandStream
extends AbstractForkInputStream

Reader stream sends commands to forked jvm std-input-stream.

Since:

2.19

Author:

Tibor Digana (tibor17)

See Also:

Command

Constructor Summary

Constructors

Constructor and Description
AbstractCommandStream()

Method Summary

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 boolean	canContinue() Opposite to isClosed().
protected void	invalidateInternalBuffer() Returns quietly and immediately.
protected abstract boolean	isClosed()
protected abstract Command	nextCommand()
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, read, read, reset, skip

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

Constructor Detail

AbstractCommandStream

public AbstractCommandStream()

Method Detail

isClosed

protected abstract boolean isClosed()

canContinue

protected boolean canContinue()

Opposite to 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 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()

invalidateInternalBuffer

protected final void invalidateInternalBuffer()

Returns quietly and immediately.

read

public int read()
         throws IOException

Used by single thread in StreamFeeder class.

Specified by:

read in class InputStream

Returns:

Throws:

IOException