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

Class TestLessInputStream.TestLessInputStreamBuilder

java.lang.Object

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

Enclosing class:

TestLessInputStream

public static final class TestLessInputStream.TestLessInputStreamBuilder
extends Object

Builds streams, registers cachable commands and provides accessible API to dispatch immediate commands to all atomically alive streams.

Constructor Summary

Constructors

Constructor	Description
TestLessInputStreamBuilder()

Method Summary

Modifier and Type	Method	Description
TestLessInputStream	build()
NotifiableTestStream	getCachableCommands()	Cached commands are sent to all alive or future alive forks.
NotifiableTestStream	getImmediateCommands()	Only NotifiableTestStream.noop() and NotifiableTestStream.shutdown(Shutdown) are supported.
void	removeStream(TestLessInputStream is)

Methods inherited from class java.lang.Object

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

Constructor Details

TestLessInputStreamBuilder

public TestLessInputStreamBuilder()

Method Details

build

public TestLessInputStream build()

removeStream

public void removeStream(TestLessInputStream is)

getImmediateCommands

public NotifiableTestStream getImmediateCommands()

Only NotifiableTestStream.noop() and NotifiableTestStream.shutdown(Shutdown) are supported. Another methods throw UnsupportedOperationException.

Returns:

commands which are immediately transmitted once to all alive forked JVMs, not cached. As opposite to cached commands, the immediate commands disappear and cannot be seen by any fork initiated after the command has dispatched.

getCachableCommands

public NotifiableTestStream getCachableCommands()

Cached commands are sent to all alive or future alive forks. These are termination commands which are not reversible and therefore only NotifiableTestStream.shutdown(Shutdown) and NotifiableTestStream.skipSinceNextTest() are supported. Another methods throw UnsupportedOperationException.

Returns:

commands which are cached for currently alive or future forks.