AbstractCommandStream

java.lang.Object

java.io.InputStream

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

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

All Implemented Interfaces:: Closeable, AutoCloseable, NotifiableTestStream

Direct Known Subclasses:: TestLessInputStream, TestProvidingInputStream

public abstract class AbstractCommandStream extends AbstractForkInputStream

Reader stream sends commands to forked jvm std-input-stream.

Since:

2.19

Author:

Tibor Digana (tibor17)

See Also:

Command

Constructor Summary

Constructors

Constructor

Description

AbstractCommandStream()
Method Summary

Modifier and Type

Method

Description

protected void

beforeNextCommand()

Possibly waiting for next command (see nextCommand()) unless the stream is atomically closed (see isClosed() returns true) before this method has returned.

protected boolean

canContinue()

Opposite to isClosed().

protected final void

invalidateInternalBuffer()

Returns quietly and immediately.

protected abstract boolean

isClosed()

protected abstract org.apache.maven.surefire.booter.Command

nextCommand()

int

read()

Used by single thread in StreamFeeder class.

Methods inherited from class org.apache.maven.plugin.surefire.booterclient.lazytestprovider.AbstractForkInputStream
setFlushReceiverProvider, tryFlush

Methods inherited from class java.io.InputStream
available, close, mark, markSupported, nullInputStream, read, read, readAllBytes, readNBytes, readNBytes, reset, skip, skipNBytes, transferTo

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

Methods inherited from interface org.apache.maven.plugin.surefire.booterclient.lazytestprovider.NotifiableTestStream
acknowledgeByeEventReceived, noop, provideNewTest, shutdown, skipSinceNextTest

Constructor Details
- AbstractCommandStream
  
  public AbstractCommandStream()
Method Details
- isClosed
  
  protected abstract boolean isClosed()
- canContinue
  
  protected boolean canContinue()
  
  Opposite to isClosed().
  
  Returns:
  
  true if not closed
- beforeNextCommand
  
  protected void beforeNextCommand() throws IOException
  
  Possibly waiting for next command (see nextCommand()) unless the stream is atomically closed (see isClosed() returns true) before this method has returned.
  
  Throws:
  
  IOException - stream error while waiting for notification regarding next test required by forked jvm
- nextCommand
  
  protected abstract org.apache.maven.surefire.booter.Command nextCommand()
- invalidateInternalBuffer
  
  protected final void invalidateInternalBuffer()
  
  Returns quietly and immediately.
- read
  
  public int read() throws IOException
  
  Used by single thread in StreamFeeder class.
  
  Specified by:
  
  read in class InputStream
  
  Returns:
  
  Throws:
  
  IOException