Package 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:

java.io.Closeable, java.lang.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

See Also:

Command

Field Summary

Fields

Modifier and Type	Field	Description
private byte[]	currentBuffer
private int	currentPos

Constructor Summary

Constructors

Constructor	Description
AbstractCommandStream()

Method Summary

Modifier and Type	Method	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, nullInputStream, read, read, readAllBytes, readNBytes, readNBytes, reset, skip, 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 Detail

currentBuffer

private byte[] currentBuffer

currentPos

private int currentPos

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 java.io.IOException

Possibly waiting for next command (see nextCommand()) unless the stream is atomically closed (see isClosed() returns true) 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()

invalidateInternalBuffer

protected final void invalidateInternalBuffer()

Returns quietly and immediately.

read

public int read()
         throws java.io.IOException

Used by single thread in StreamFeeder class.

Specified by:

read in class java.io.InputStream

Returns:

Throws:

java.io.IOException