- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for connectStream (0.16 sec)
-
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/bootstrap/DaemonOutputConsumerTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 2.5K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/process/internal/streams/EmptyStdInStreamsHandler.java
import java.util.concurrent.Executor; /** * A handler that writes nothing to the process' stdin */ public class EmptyStdInStreamsHandler implements StreamsHandler { @Override public void connectStreams(Process process, String processName, Executor executor) { try { process.getOutputStream().close(); } catch (IOException e) { throw new UncheckedIOException(e); } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jul 11 16:06:58 UTC 2023 - 1.4K bytes - Viewed (0) -
platforms/core-runtime/process-services/src/main/java/org/gradle/process/internal/StreamsHandler.java
import java.util.concurrent.Executor; public interface StreamsHandler extends Stoppable { /** * Collects whatever state is required the given process. Should not start work. */ void connectStreams(Process process, String processName, Executor executor); /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:10:02 UTC 2023 - 1.6K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/bootstrap/DaemonOutputConsumer.java
DaemonStartupCommunication startupCommunication = new DaemonStartupCommunication(); private String processOutput; private InputStream processStdOutput; @Override public void connectStreams(Process process, String processName, Executor executor) { processStdOutput = process.getInputStream(); } @Override @SuppressWarnings("DefaultCharset") public void start() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:38 UTC 2024 - 2.7K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/process/internal/streams/ForwardStdinStreamsHandler.java
private ExecOutputHandleRunner standardInputWriter; public ForwardStdinStreamsHandler(InputStream input) { this.input = input; } @Override public void connectStreams(Process process, String processName, Executor executor) { this.executor = executor; /* There's a potential problem here in that DisconnectableInputStream reads from input in the background.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jul 11 16:06:58 UTC 2023 - 2.7K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/process/internal/streams/OutputStreamsForwarder.java
this.errorOutput = errorOutput; this.readErrorStream = readErrorStream; this.completed = new CountDownLatch(readErrorStream ? 2 : 1); } @Override public void connectStreams(Process process, String processName, Executor executor) { this.executor = executor;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jul 11 16:06:58 UTC 2023 - 3.2K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/process/internal/ExecHandleRunner.java
} ProcessBuilder processBuilder = processBuilderFactory.createProcessBuilder(execHandle); Process process = processLauncher.start(processBuilder); streamsHandler.connectStreams(process, execHandle.getDisplayName(), executor); this.process = process; } finally { lock.unlock(); } } private void completed(int exitValue) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 05 19:36:14 UTC 2023 - 4.8K bytes - Viewed (0)