- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 412 for dispatchTo (0.16 sec)
-
mockwebserver/api/mockwebserver3.api
public abstract class mockwebserver3/Dispatcher { public fun <init> ()V public abstract fun dispatch (Lmockwebserver3/RecordedRequest;)Lmockwebserver3/MockResponse; public fun peek ()Lmockwebserver3/MockResponse; public fun shutdown ()V } public final class mockwebserver3/MockResponse { public static final field Companion Lmockwebserver3/MockResponse$Companion; public fun <init> ()V public fun <init> (I)V public fun <init> (ILokhttp3/Headers;)V
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Tue Jan 03 21:59:45 UTC 2023 - 12.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/KotlinSourceModernTest.kt
} @Test fun dispatcher() { var dispatcher = Dispatcher() dispatcher = Dispatcher(Executors.newCachedThreadPool()) val maxRequests: Int = dispatcher.maxRequests dispatcher.maxRequests = 0 val maxRequestsPerHost: Int = dispatcher.maxRequestsPerHost dispatcher.maxRequestsPerHost = 0 val executorService: ExecutorService = dispatcher.executorService
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 01 14:21:25 UTC 2024 - 46.5K 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) -
okhttp/src/test/java/okhttp3/DispatcherTest.kt
object : WebSocketListener() { } val dispatcher = Dispatcher(executor) val listener = RecordingEventListener() var client = clientTestRule.newClientBuilder() .dns { throw UnknownHostException() } .dispatcher(dispatcher) .eventListenerFactory(clientTestRule.wrap(listener)) .build() @BeforeEach fun setUp() { dispatcher.maxRequests = 20 dispatcher.maxRequestsPerHost = 10
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Fri Apr 05 03:30:42 UTC 2024 - 12.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
// We use a re-entrant dispatcher to initiate one HTTPS connection while the other is in flight. server.dispatcher = object : Dispatcher() { var requestCount = 0 override fun dispatch(request: RecordedRequest): MockResponse { val result = queueDispatcher.dispatch(request) requestCount++ if (requestCount == 1) {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 11 22:09:35 UTC 2024 - 75.3K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/eventspy/internal/EventSpyRepositoryListener.java
private final EventSpyDispatcher dispatcher; private final RepositoryListener delegate; EventSpyRepositoryListener(EventSpyDispatcher dispatcher, RepositoryListener delegate) { this.dispatcher = dispatcher; this.delegate = delegate; } @Override public void artifactDeployed(RepositoryEvent event) { dispatcher.onEvent(event); delegate.artifactDeployed(event);
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Nov 22 13:26:01 UTC 2022 - 4.3K 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) -
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)