- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for connectStream (0.12 sec)
-
build-logic/cleanup/src/main/java/gradlebuild/cleanup/services/KillLeakingJavaProcesses.java
Process process = new ProcessBuilder().command(args).start(); CountDownLatch latch = new CountDownLatch(2); ByteArrayOutputStream stdout = connectStream(process.getInputStream(), latch); ByteArrayOutputStream stderr = connectStream(process.getErrorStream(), latch); process.waitFor(1, TimeUnit.MINUTES); latch.await(1, TimeUnit.MINUTES);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 26 09:46:00 UTC 2024 - 11.3K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/timeout/JavaProcessStackTracesMonitor.java
Process process = new ProcessBuilder().command(args).start(); CountDownLatch latch = new CountDownLatch(2); ByteArrayOutputStream stdout = connectStream(process.getInputStream(), latch); ByteArrayOutputStream stderr = connectStream(process.getErrorStream(), latch); process.waitFor(1, TimeUnit.MINUTES); latch.await(1, TimeUnit.MINUTES);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 10.2K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/process/internal/DefaultExecHandle.java
} } private class CompositeStreamsHandler implements StreamsHandler { @Override public void connectStreams(Process process, String processName, Executor executor) { inputHandler.connectStreams(process, processName, executor); outputHandler.connectStreams(process, processName, executor); } @Override public void start() { inputHandler.start();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jan 26 14:58:23 UTC 2024 - 15.2K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/process/internal/DefaultExecHandleSpec.groovy
when: execHandle.start() def result = execHandle.waitForFinish() then: result.rethrowFailure() 1 * streamsHandler.connectStreams(_ as Process, "foo proc", _ as Executor) 1 * streamsHandler.start() 1 * streamsHandler.stop() 0 * streamsHandler._ } @Timeout(2) @Ignore //not yet implemented
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Dec 23 03:44:52 UTC 2021 - 14.9K bytes - Viewed (0)