- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for UserResponse (0.33 sec)
-
platforms/core-runtime/daemon-protocol/src/main/java/org/gradle/launcher/daemon/protocol/UserResponse.java
package org.gradle.launcher.daemon.protocol; /** * Carries the user's response to a {@link org.gradle.internal.logging.events.PromptOutputEvent}. */ public class UserResponse extends InputMessage { private final String response; public UserResponse(String response) { this.response = response; } public String getResponse() { return response; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 09 04:50:46 UTC 2024 - 1005 bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http/RetryAndFollowUpInterceptor.kt
val responseCode = userResponse.code val method = userResponse.request.method when (responseCode) { HTTP_PROXY_AUTH -> { val selectedProxy = route!!.proxy if (selectedProxy.type() != Proxy.Type.HTTP) { throw ProtocolException("Received HTTP_PROXY_AUTH (407) code while not using proxy") } return client.proxyAuthenticator.authenticate(route, userResponse) }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 15 13:24:48 UTC 2024 - 12.1K 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/launcher/src/main/java/org/gradle/tooling/internal/provider/ForwardStdInToThisProcess.java
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/ClientInputForwarder.java
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; /** * Forwards user input received from the client to this process' System.in and {@link UserInputReader}. */
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/daemon-protocol/src/main/java/org/gradle/launcher/daemon/protocol/DaemonMessageSerializer.java
private static class UserResponseSerializer implements Serializer<UserResponse> { @Override public void write(Encoder encoder, UserResponse message) throws Exception { encoder.writeString(message.getResponse()); } @Override public UserResponse read(Decoder decoder) throws Exception { return new UserResponse(decoder.readString()); } }
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/client-services/src/test/groovy/org/gradle/internal/daemon/client/clientinput/DaemonClientInputForwarderTest.groovy
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 import static org.gradle.util.internal.TextUtil.toPlatformLineSeparators
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
import org.gradle.launcher.daemon.protocol.CloseInput; import org.gradle.launcher.daemon.protocol.ForwardInput; import org.gradle.launcher.daemon.protocol.InputMessage; import org.gradle.launcher.daemon.protocol.UserResponse; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.nio.charset.Charset; import java.util.concurrent.Executor;
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/test/groovy/org/gradle/launcher/daemon/protocol/DaemonMessageSerializerTest.groovy
messageResult.bytes == message.bytes } def "can serialize UserResponse messages"() { expect: def message = new UserResponse("greetings") def messageResult = serialize(message, serializer) messageResult instanceof UserResponse messageResult.response == message.response } def "can serialize user input request event"() {
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/DefaultDaemonConnection.java
if (command instanceof CloseInput) { handler.onEndOfInput(); return true; } else if (command instanceof UserResponse) { handler.onUserResponse((UserResponse) command); } else { handler.onInput((ForwardInput) command); } } catch (Exception e) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:51:37 UTC 2024 - 16K bytes - Viewed (0)