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.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private final class	TestLessInputStream.TestLessInputStreamBuilder.CachableCommands	Event is persisted.
private final class	TestLessInputStream.TestLessInputStreamBuilder.CIt
private final 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 final Queue<TestLessInputStream>	aliveStreams
private final TestLessInputStream.TestLessInputStreamBuilder.CachableCommands	cachableCommands
private final TestLessInputStream.TestLessInputStreamBuilder.Node	head
private final TestLessInputStream.TestLessInputStreamBuilder.ImmediateCommands	immediateCommands
private final Iterable<Command>	iterableCachable
private final ReentrantReadWriteLock	rwLock

Constructor Summary

Constructors

Constructor	Description
TestLessInputStreamBuilder()

Method Summary

Modifier and Type	Method	Description
private boolean	addTailNodeIfAbsent(Command command)
TestLessInputStream	build()
NotifiableTestStream	getCachableCommands()
NotifiableTestStream	getImmediateCommands()
(package private) 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 Details

rwLock

private final ReentrantReadWriteLock rwLock

aliveStreams

private final 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 Iterable<Command> iterableCachable

Constructor Details

TestLessInputStreamBuilder

public TestLessInputStreamBuilder()

Method Details

build

public TestLessInputStream build()

removeStream

public void removeStream(TestLessInputStream is)

getImmediateCommands

public NotifiableTestStream getImmediateCommands()

getCachableCommands

public NotifiableTestStream getCachableCommands()

getIterableCachable

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)