- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for ForwardInput (0.39 sec)
-
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/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/client/DaemonClient.java
import org.gradle.launcher.daemon.protocol.DaemonUnavailable; import org.gradle.launcher.daemon.protocol.Failure; import org.gradle.launcher.daemon.protocol.Finished; import org.gradle.launcher.daemon.protocol.ForwardInput; import org.gradle.launcher.daemon.protocol.Message; import org.gradle.launcher.daemon.protocol.OutputMessage; import org.gradle.launcher.daemon.protocol.Result; import org.gradle.launcher.daemon.protocol.Stop;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:54:56 UTC 2024 - 16.5K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/DefaultDaemonConnection.java
import org.gradle.launcher.daemon.protocol.Cancel; import org.gradle.launcher.daemon.protocol.CloseInput; import org.gradle.launcher.daemon.protocol.DaemonUnavailable; import org.gradle.launcher.daemon.protocol.ForwardInput; import org.gradle.launcher.daemon.protocol.InputMessage; import org.gradle.launcher.daemon.protocol.Message; import org.gradle.launcher.daemon.protocol.OutputMessage; import org.gradle.launcher.daemon.protocol.Result;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:51:37 UTC 2024 - 16K bytes - Viewed (0)