- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for DaemonClientInputForwarder (0.38 sec)
-
platforms/core-runtime/client-services/src/main/java/org/gradle/internal/daemon/client/clientinput/DaemonClientInputForwarder.java
* * <p>Uses a single reader thread to perform all operations. */ public class DaemonClientInputForwarder implements Stoppable { private final ForwardingUserInput forwarder; private final GlobalUserInputReceiver userInput; private final ExecutorService executor; public DaemonClientInputForwarder( InputStream inputStream, Dispatch<? super InputMessage> dispatch,
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:53:31 UTC 2024 - 5.8K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/tooling/internal/provider/ForwardStdInToThisProcess.java
} else { throw new IllegalArgumentException(); } }); return forwarder.forwardInput(stdinHandler -> { DaemonClientInputForwarder inputForwarder = new DaemonClientInputForwarder(finalStandardInput, message -> { if (message instanceof UserResponse) { stdinHandler.onUserResponse((UserResponse) message);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:53:31 UTC 2024 - 3.8K bytes - Viewed (0) -
platforms/core-runtime/client-services/src/test/groovy/org/gradle/internal/daemon/client/clientinput/DaemonClientInputForwarderTest.groovy
receivedCommand() instanceof CloseInput } def forwarder def createForwarder() { userInputReceiver.attachConsole(Mock(OutputEventListener)) forwarder = new DaemonClientInputForwarder(inputStream, dispatch, userInputReceiver) } def setup() { createForwarder() } def closeInput() { source.close() }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 12:11:05 UTC 2024 - 5K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/client/DaemonClient.java
private Object monitorBuild(Build build, DaemonDiagnostics diagnostics, DaemonClientConnection connection, BuildCancellationToken cancellationToken, BuildEventConsumer buildEventConsumer) { DaemonClientInputForwarder inputForwarder = new DaemonClientInputForwarder(buildStandardInput, connection, userInput); DaemonCancelForwarder cancelForwarder = new DaemonCancelForwarder(connection, cancellationToken); try {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:54:56 UTC 2024 - 16.5K bytes - Viewed (0)