public final class TestProvidingInputStream extends DefaultCommandReader
InputStream
that, when read, provides test class names out of a queue.
provideNewTest()
has been invoked.
FlushReceiver
provided by the FlushReceiverProvider
that can be set using
AbstractCommandReader.setFlushReceiverProvider(FlushReceiverProvider)
.
ForkStarter
by one Thread.Constructor and Description |
---|
TestProvidingInputStream(Queue<String> testClassNames)
C'tor
|
Modifier and Type | Method and 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 org.apache.maven.surefire.api.booter.Command |
nextCommand() |
void |
noop() |
void |
provideNewTest()
Signal that a new test is to be provided.
|
void |
shutdown(org.apache.maven.surefire.api.booter.Shutdown shutdownType) |
void |
skipSinceNextTest()
Sends an event to a fork jvm in order to skip tests.
|
canContinue, readNextCommand
setFlushReceiverProvider, tryFlush
public void skipSinceNextTest()
NotifiableTestStream
public void shutdown(org.apache.maven.surefire.api.booter.Shutdown shutdownType)
public void noop()
public void acknowledgeByeEventReceived()
protected org.apache.maven.surefire.api.booter.Command nextCommand()
nextCommand
in class DefaultCommandReader
protected void beforeNextCommand() throws IOException
DefaultCommandReader
DefaultCommandReader.nextCommand()
) unless the stream is atomically
closed (see CommandReader.isClosed()
returns true
) before this method has returned.beforeNextCommand
in class DefaultCommandReader
IOException
- stream error while waiting for notification regarding next test required by forked jvmpublic boolean isClosed()
public void provideNewTest()
public void close()
Copyright © 2004–2020 The Apache Software Foundation. All rights reserved.