TestLessInputStream (Maven Surefire Common 3.0.0 API)

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.TestLessInputStream

All Implemented Interfaces:: Closeable, AutoCloseable, NotifiableTestStream, CommandReader

public final class TestLessInputStream extends DefaultCommandReader

Dispatches commands without tests.

Since:: 2.19
Author:: Tibor Digana (tibor17)

Nested Class Summary

Nested Classes

Modifier and Type

Class

Description

static final class

TestLessInputStream.TestLessInputStreamBuilder

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

Modifier and Type

Method

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()

Forked jvm notifies master process to provide a new test.

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

Method Details
- provideNewTest
  
  public void provideNewTest()
  
  Description copied from interface: NotifiableTestStream
  
  Forked jvm notifies master process to provide a new test.
  Notifies TestProvidingInputStream in order to dispatch a new test back to the forked jvm (particular fork which hits this call); or do nothing in TestLessInputStream.
- 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()
- isClosed
  
  public boolean isClosed()
- 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
- close
  
  public void close()