ThreadedStreamConsumer.Pumper

java.lang.Object

org.apache.maven.plugin.surefire.booterclient.output.ThreadedStreamConsumer.Pumper

All Implemented Interfaces:: Runnable

Enclosing class:: ThreadedStreamConsumer

final class ThreadedStreamConsumer.Pumper extends Object implements Runnable

Field Summary

Fields

Modifier and Type

Field

Description

private final MultipleFailureException

errors

private final EventHandler<Event>

target
Constructor Summary

Constructors

Constructor

Description

Pumper(EventHandler<Event> target)
Method Summary

Modifier and Type

Method

Description

(package private) boolean

hasErrors()

void

run()

Calls ForkClient.handleEvent(Event) which may throw any RuntimeException.
Even if ForkClient is not fault-tolerant, this method MUST be fault-tolerant and thus the try-catch block must be inside of the loop which prevents from loosing events from EventHandler.

(package private) void

throwErrors()

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details
- target
  
  private final EventHandler<Event> target
- errors
  
  private final MultipleFailureException errors
Constructor Details
- Pumper
  
  Pumper(EventHandler<Event> target)
Method Details
- run
  
  public void run()
  
  Calls ForkClient.handleEvent(Event) which may throw any RuntimeException.
  Even if ForkClient is not fault-tolerant, this method MUST be fault-tolerant and thus the try-catch block must be inside of the loop which prevents from loosing events from EventHandler.
  If ConsoleOutputFileReporter.writeTestOutput(org.apache.maven.surefire.api.report.TestOutputReportEntry) throws IOException and then target.consumeLine() throws any RuntimeException, this method MUST NOT skip reading the events from the forked JVM; otherwise we could simply lost events e.g. acquire-next-test which means that ForkClient could hang on waiting for old test to complete and therefore the plugin could be permanently in progress.
  
  Specified by:
  
  run in interface Runnable
- hasErrors
  
  boolean hasErrors()
- throwErrors
  
  void throwErrors() throws IOException
  
  Throws:
  
  IOException