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 java.lang.Object

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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	TestLessInputStream.TestLessInputStreamBuilder.CachableCommands	Event is persisted.
private class	TestLessInputStream.TestLessInputStreamBuilder.CIt
private class	TestLessInputStream.TestLessInputStreamBuilder.ImmediateCommands	Event is called just now for all alive streams and command is not persisted.
private static class	TestLessInputStream.TestLessInputStreamBuilder.Node

Field Summary

Fields

Modifier and Type	Field	Description
private java.util.Queue<TestLessInputStream>	aliveStreams
private TestLessInputStream.TestLessInputStreamBuilder.CachableCommands	cachableCommands
private TestLessInputStream.TestLessInputStreamBuilder.Node	head
private TestLessInputStream.TestLessInputStreamBuilder.ImmediateCommands	immediateCommands
private java.lang.Iterable<Command>	iterableCachable
private java.util.concurrent.locks.ReentrantReadWriteLock	rwLock

Constructor Summary

Constructors

Constructor	Description
TestLessInputStreamBuilder()

Method Summary

Modifier and Type	Method	Description
private boolean	addTailNodeIfAbsent(Command command)
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.
(package private) java.lang.Iterable<Command>	getIterableCachable()	The iterator is not thread safe.
private static TestLessInputStream.TestLessInputStreamBuilder.Node	nextCachedNode(TestLessInputStream.TestLessInputStreamBuilder.Node current)
void	removeStream(TestLessInputStream is)

Methods inherited from class java.lang.Object

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

Field Detail

rwLock

private final java.util.concurrent.locks.ReentrantReadWriteLock rwLock

aliveStreams

private final java.util.Queue<TestLessInputStream> aliveStreams

immediateCommands

private final TestLessInputStream.TestLessInputStreamBuilder.ImmediateCommands immediateCommands

cachableCommands

private final TestLessInputStream.TestLessInputStreamBuilder.CachableCommands cachableCommands

head

private final TestLessInputStream.TestLessInputStreamBuilder.Node head

iterableCachable

private final java.lang.Iterable<Command> iterableCachable

Constructor Detail

TestLessInputStreamBuilder

public TestLessInputStreamBuilder()

Method Detail

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.

getIterableCachable

java.lang.Iterable<Command> getIterableCachable()

The iterator is not thread safe.

addTailNodeIfAbsent

private boolean addTailNodeIfAbsent(Command command)

nextCachedNode

private static TestLessInputStream.TestLessInputStreamBuilder.Node nextCachedNode(TestLessInputStream.TestLessInputStreamBuilder.Node current)