- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for forwardInput (0.68 sec)
-
platforms/core-runtime/daemon-protocol/src/main/java/org/gradle/launcher/daemon/protocol/ForwardInput.java
*/ package org.gradle.launcher.daemon.protocol; /** * Carries some text that should be made available via the daemon's System.in */ public class ForwardInput extends InputMessage { private final byte[] bytes; public ForwardInput(byte[] bytes) { this.bytes = bytes; } public byte[] getBytes() { return bytes; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 09 04:50:46 UTC 2024 - 966 bytes - Viewed (0) -
platforms/core-runtime/daemon-services/src/main/java/org/gradle/internal/daemon/clientinput/ClientInputForwarder.java
import org.gradle.internal.IoActions; import org.gradle.internal.logging.events.OutputEvent; import org.gradle.internal.logging.events.OutputEventListener; import org.gradle.launcher.daemon.protocol.ForwardInput; import org.gradle.launcher.daemon.protocol.UserResponse; import java.io.InputStream; import java.util.function.Function; /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:51:37 UTC 2024 - 3.1K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/server/DefaultDaemonConnectionTest.groovy
daemonConnection.stop() } def "forwards queued input events to stdin handler until end of input received"() { StdinHandler handler = Mock() def input1 = new ForwardInput("hello".bytes) def input2 = new ForwardInput("hello".bytes) def closeInput = new CloseInput() def received = new CountDownLatch(1) when: daemonConnection.onStdin(handler)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:51:37 UTC 2024 - 11.7K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/tooling/internal/provider/ForwardStdInToThisProcess.java
} }); return forwarder.forwardInput(stdinHandler -> { DaemonClientInputForwarder inputForwarder = new DaemonClientInputForwarder(finalStandardInput, message -> { if (message instanceof UserResponse) { stdinHandler.onUserResponse((UserResponse) message); } else if (message instanceof ForwardInput) { stdinHandler.onInput((ForwardInput) 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/daemon-services/src/main/java/org/gradle/internal/daemon/clientinput/StdinHandler.java
*/ package org.gradle.internal.daemon.clientinput; import org.gradle.launcher.daemon.protocol.ForwardInput; import org.gradle.launcher.daemon.protocol.UserResponse; public interface StdinHandler { void onUserResponse(UserResponse input); void onInput(ForwardInput input); void onEndOfInput();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:51:37 UTC 2024 - 925 bytes - Viewed (0) -
platforms/core-runtime/client-services/src/test/groovy/org/gradle/internal/daemon/client/clientinput/DaemonClientInputForwarderTest.groovy
import org.gradle.internal.logging.events.PromptOutputEvent import org.gradle.internal.logging.events.ReadStdInEvent import org.gradle.launcher.daemon.protocol.CloseInput import org.gradle.launcher.daemon.protocol.ForwardInput import org.gradle.launcher.daemon.protocol.UserResponse import org.gradle.util.ConcurrentSpecification import java.util.concurrent.LinkedBlockingQueue import java.util.concurrent.TimeUnit
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/client-services/src/main/java/org/gradle/internal/daemon/client/clientinput/DaemonClientInputForwarder.java
} else { String text = new String(buffer, 0, nread); byte[] result = text.getBytes(Charset.defaultCharset()); ForwardInput message = new ForwardInput(result); dispatch.dispatch(message); } }); } @Override public void readAndForwardText(Normalizer normalizer) {
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/daemon-protocol/src/main/java/org/gradle/launcher/daemon/protocol/DaemonMessageSerializer.java
private static class ForwardInputSerializer implements Serializer<ForwardInput> { @Override public void write(Encoder encoder, ForwardInput message) throws Exception { encoder.writeBinary(message.getBytes()); } @Override public ForwardInput read(Decoder decoder) throws Exception { return new ForwardInput(decoder.readBinary()); } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:54:56 UTC 2024 - 18.8K bytes - Viewed (0) -
platforms/core-runtime/daemon-protocol/src/test/groovy/org/gradle/launcher/daemon/protocol/DaemonMessageSerializerTest.groovy
messageResult instanceof CloseInput } def "can serialize ForwardInput messages"() { expect: def message = new ForwardInput("greetings".bytes) def messageResult = serialize(message, serializer) messageResult instanceof ForwardInput messageResult.bytes == message.bytes } def "can serialize UserResponse messages"() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:54:56 UTC 2024 - 12.3K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/exec/ForwardClientInput.java
this.forwarder = new ClientInputForwarder(inputReader, eventDispatch); } @Override public void execute(final DaemonCommandExecution execution) { forwarder.forwardInput(stdinHandler -> { execution.getConnection().onStdin(stdinHandler); try { execution.proceed(); } finally { execution.getConnection().onStdin(null);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:51:37 UTC 2024 - 1.8K bytes - Viewed (0)