- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for PipedOutputStream (0.32 sec)
-
testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/executer/ForkingGradleHandle.java
private final Action<ExecutionResult> resultAssertion; private final PipedOutputStream stdinPipe; private final boolean isDaemon; private final DurationMeasurement durationMeasurement; private final AtomicReference<ExecHandle> execHandleRef = new AtomicReference<>();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 9K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/executer/GradleHandle.java
* limitations under the License. */ package org.gradle.integtests.fixtures.executer; import java.io.PipedOutputStream; public interface GradleHandle { /** * Returns the stream for writing to stdin. */ PipedOutputStream getStdinPipe(); /** * Returns the stdout output currently received from the build. This is live. */ String getStandardOutput();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 2.1K bytes - Viewed (0) -
testing/integ-test/src/integTest/groovy/org/gradle/integtests/StdioIntegrationTest.groovy
if (!line) { break } print "[$line]" } } } ''' executer.withStdinPipe(new PipedOutputStream() { @Override void connect(PipedInputStream snk) throws IOException { super.connect(snk) write(TextUtil.toPlatformLineSeparators("abc\n123").bytes)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 30 05:02:18 UTC 2024 - 2.7K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/executer/ParallelForkingGradleHandle.java
import org.gradle.process.internal.AbstractExecHandleBuilder; import org.gradle.util.internal.IncubationLogger; import java.io.PipedOutputStream; import static java.lang.String.format; public class ParallelForkingGradleHandle extends ForkingGradleHandle {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 2.6K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/integTest/groovy/org/gradle/launcher/continuous/CancellationContinuousIntegrationTest.groovy
def "does not cancel on EOT or by closing System.in when not interactive"() { when: executer.beforeExecute { it.withForceInteractive(false).withStdinPipe(new PipedOutputStream() { @Override void connect(PipedInputStream snk) throws IOException { super.connect(snk) close() } }) }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 2.5K bytes - Viewed (0) -
testing/internal-testing/src/main/groovy/org/gradle/integtests/fixtures/RedirectStdinExtension.groovy
} } private void initPipe() { if (stdinPipe == null) { emulatedSystemIn = new PipedInputStream(); try { stdinPipe = new PipedOutputStream(emulatedSystemIn); } catch (IOException e) { throw UncheckedException.throwAsUncheckedException(e); } } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 2.5K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/executer/GradleExecuter.java
*/ GradleExecuter withStdinPipe(); /** * Sets a stream to use for writing to stdin. */ GradleExecuter withStdinPipe(PipedOutputStream stdInPipe); default GradleExecuter withStdIn(String input) { return withStdinPipe(new PipedOutputStream() { @Override public void connect(PipedInputStream snk) throws IOException { super.connect(snk);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 20.3K bytes - Viewed (0) -
platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r43/CapturingUserInputCrossVersionSpec.groovy
} private void runBuildWithStandardInput(ProjectConnection connection) { def build = basicBuildConfiguration(connection) def stdin = new PipedInputStream() def stdinWriter = new PipedOutputStream(stdin) build.standardInput = stdin def resultHandler = new TestResultHandler() build.run(resultHandler) poll(60) { assert getOutput().contains(PROMPT)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Apr 01 19:25:32 UTC 2024 - 3.6K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/executer/AbstractGradleExecuter.java
return executable; } @Override public GradleExecuter withStdinPipe() { return withStdinPipe(new PipedOutputStream()); } @Override public GradleExecuter withStdinPipe(PipedOutputStream stdInPipe) { this.stdinPipe = stdInPipe; return this; } public InputStream connectStdIn() { try {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 55.1K bytes - Viewed (0) -
platforms/core-runtime/client-services/src/test/groovy/org/gradle/internal/daemon/client/clientinput/DaemonClientInputForwarderTest.groovy
import java.util.concurrent.TimeUnit import static org.gradle.util.internal.TextUtil.toPlatformLineSeparators class DaemonClientInputForwarderTest extends ConcurrentSpecification { def source = new PipedOutputStream() def inputStream = new PipedInputStream(source) def received = new LinkedBlockingQueue() def dispatch = { received << it } as Dispatch def userInputReceiver = new DefaultUserInputReceiver()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 12:11:05 UTC 2024 - 5K bytes - Viewed (0)