- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 215 for dispatchTo (0.26 sec)
-
samples/slack/src/main/java/okhttp3/slack/OAuthSessionFactory.java
package okhttp3.slack; import java.io.Closeable; import java.io.IOException; import java.security.SecureRandom; import java.util.LinkedHashMap; import java.util.Map; import okhttp3.HttpUrl; import okhttp3.mockwebserver.Dispatcher; import okhttp3.mockwebserver.MockResponse; import okhttp3.mockwebserver.MockWebServer; import okhttp3.mockwebserver.RecordedRequest; import okio.ByteString; /**
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Aug 12 07:26:27 UTC 2021 - 3.8K bytes - Viewed (0) -
samples/static-server/src/main/java/okhttp3/sample/SampleServer.java
import javax.net.ssl.SSLContext; import javax.net.ssl.TrustManagerFactory; import okhttp3.mockwebserver.Dispatcher; import okhttp3.mockwebserver.MockResponse; import okhttp3.mockwebserver.MockWebServer; import okhttp3.mockwebserver.RecordedRequest; import okio.Buffer; import okio.Okio; public class SampleServer extends Dispatcher { private final SSLContext sslContext; private final String root; private final int port;
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Jan 02 02:50:44 UTC 2019 - 4.7K bytes - Viewed (0) -
samples/bookinfo/src/ratings/ratings.js
ratings: { 'Reviewer1': 5, 'Reviewer2': 4 } } } function handleRequest (request, response) { try { console.log(request.method + ' ' + request.url) dispatcher.dispatch(request, response) } catch (err) { console.log(err) } } var server = http.createServer(handleRequest) process.on('SIGTERM', function () { console.log("SIGTERM received")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Sep 02 00:29:57 UTC 2022 - 8.8K bytes - Viewed (0) -
docs/features/calls.md
## Dispatch For synchronous calls, you bring your own thread and are responsible for managing how many simultaneous requests you make. Too many simultaneous connections wastes resources; too few harms latency.
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Feb 06 02:19:09 UTC 2022 - 3.9K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/exec/DaemonConnectionBackedEventConsumer.java
import java.util.concurrent.BlockingQueue; import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.TimeUnit; /** * An event consumer that asynchronously dispatches events to the client. */ class DaemonConnectionBackedEventConsumer implements BuildEventConsumer { private final DaemonCommandExecution execution;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 2.9K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/ObjectConnectionBuilder.java
public interface ObjectConnectionBuilder { /** * Creates a transmitter for outgoing messages on the given type. The returned object is thread-safe. * * <p>Method invocations on the transmitter object are dispatched asynchronously to a corresponding handler in the peer. Method invocations are * called on the handler in the same order that they were called on the transmitter object.</p> * * @param type The type
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 05 19:36:14 UTC 2023 - 2.8K bytes - Viewed (0) -
pkg/kubelet/active_deadline.go
func (m *activeDeadlineHandler) ShouldSync(pod *v1.Pod) bool { return m.pastActiveDeadline(pod) } // ShouldEvict returns true if the pod is past its active deadline. // It dispatches an event that the pod should be evicted if it is past its deadline. func (m *activeDeadlineHandler) ShouldEvict(pod *v1.Pod) lifecycle.ShouldEvictResponse { if !m.pastActiveDeadline(pod) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 10 10:20:09 UTC 2021 - 3.2K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/eventspy/internal/EventSpyExecutionListener.java
private final EventSpyDispatcher dispatcher; private final ExecutionListener delegate; EventSpyExecutionListener(EventSpyDispatcher dispatcher, ExecutionListener delegate) { this.dispatcher = dispatcher; this.delegate = delegate; } @Override public void projectDiscoveryStarted(ExecutionEvent event) { dispatcher.onEvent(event);
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Nov 22 13:26:01 UTC 2022 - 3.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/validating/plugin.go
}, func(a authorizer.Authorizer, m *matching.Matcher) generic.Dispatcher[PolicyHook] { return NewDispatcher(a, generic.NewPolicyMatcher(m)) }, ), } } // Validate makes an admission decision based on the request attributes. func (a *Plugin) Validate(ctx context.Context, attr admission.Attributes, o admission.ObjectInterfaces) error { return a.Plugin.Dispatch(ctx, attr, o) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 22:07:40 UTC 2024 - 7.5K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/integTest/groovy/org/gradle/internal/remote/internal/hub/MessageHubIntegrationTest.groovy
then: 1 * clientHandler.dispatch("message 1") >> { clientDispatch.dispatch("[message 1]") } 1 * clientHandler.dispatch("message 2") >> { clientDispatch.dispatch("[message 2]") } 1 * clientHandler.dispatch("message 3") 1 * clientHandler.dispatch("message 4") 1 * clientHandler.dispatch("message 5") 1 * clientHandler.dispatch("message 6")
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 9K bytes - Viewed (0)