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

Class TestProvidingInputStream

java.lang.Object

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

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

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

All Implemented Interfaces:

Closeable, AutoCloseable, NotifiableTestStream, CommandReader

public final class TestProvidingInputStream
extends DefaultCommandReader

An InputStream that, when read, provides test class names out of a queue.
The Stream provides only one test at a time, but only after provideNewTest() has been invoked.
The instance is used only in reusable forks in ForkStarter by one Thread.

Author:

Andreas Gudian, Tibor Digana (tibor17)

Constructor Summary

Constructors

Constructor and Description
TestProvidingInputStream(Queue<String> testClassNames) C'tor

Method Summary

Modifier and Type	Method and Description
void	acknowledgeByeEventReceived()
protected void	beforeNextCommand() Possibly waiting for next command (see DefaultCommandReader.nextCommand()) unless the stream is atomically closed (see CommandReader.isClosed() returns true) before this method has returned.
void	close()
boolean	isClosed()
protected Command	nextCommand()
void	noop()
void	provideNewTest() Signal that a new test is to be provided.
void	shutdown(Shutdown shutdownType)
void	skipSinceNextTest() Sends an event to a fork jvm in order to skip tests.

Methods inherited from class org.apache.maven.plugin.surefire.booterclient.lazytestprovider.DefaultCommandReader

canContinue, readNextCommand

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TestProvidingInputStream

public TestProvidingInputStream(Queue<String> testClassNames)

C'tor

Parameters:

testClassNames - source of the tests to be read from this stream

Method Detail

skipSinceNextTest

public void skipSinceNextTest()

Description copied from interface: NotifiableTestStream

Sends an event to a fork jvm in order to skip tests. Returns immediately without blocking.

shutdown

public void shutdown(Shutdown shutdownType)

noop

public void noop()

acknowledgeByeEventReceived

public void acknowledgeByeEventReceived()

nextCommand

protected Command nextCommand()

Specified by:

nextCommand in class DefaultCommandReader

beforeNextCommand

protected void beforeNextCommand()
                          throws IOException

Description copied from class: DefaultCommandReader

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

Overrides:

beforeNextCommand in class DefaultCommandReader

Throws:

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

isClosed

public boolean isClosed()

provideNewTest

public void provideNewTest()

Signal that a new test is to be provided.

close

public void close()