org.gradle.launcher.daemon.client

Class DaemonClientInputForwarder

java.lang.Object

org.gradle.launcher.daemon.client.DaemonClientInputForwarder

All Implemented Interfaces:

Stoppable

public class DaemonClientInputForwarder
extends java.lang.Object
implements Stoppable

Eagerly consumes from an input stream, sending line by line ForwardInput commands over the connection and finishing with a CloseInput command.?

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_BUFFER_SIZE

Constructor Summary

Constructors

Constructor and Description
DaemonClientInputForwarder(java.io.InputStream inputStream, BuildClientMetaData clientMetadata, Dispatch<? super IoCommand> dispatch)
DaemonClientInputForwarder(java.io.InputStream inputStream, BuildClientMetaData clientMetadata, Dispatch<? super IoCommand> dispatch, ExecutorFactory executorFactory, int bufferSize)

Method Summary

Methods

Modifier and Type	Method and Description
DaemonClientInputForwarder	start()
void	stop() Requests a graceful stop of this object.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

DEFAULT_BUFFER_SIZE

public static final int DEFAULT_BUFFER_SIZE

See Also:

Constant Field Values

Constructor Detail

DaemonClientInputForwarder

public DaemonClientInputForwarder(java.io.InputStream inputStream,
                          BuildClientMetaData clientMetadata,
                          Dispatch<? super IoCommand> dispatch)

DaemonClientInputForwarder

public DaemonClientInputForwarder(java.io.InputStream inputStream,
                          BuildClientMetaData clientMetadata,
                          Dispatch<? super IoCommand> dispatch,
                          ExecutorFactory executorFactory,
                          int bufferSize)

Method Detail

start

public DaemonClientInputForwarder start()

stop

public void stop()

Description copied from interface: Stoppable

Requests a graceful stop of this object. Blocks until all concurrent activity has been completed.

If this object has already been stopped, this method does nothing.

Specified by:

stop in interface Stoppable