- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 330 for dispatchTo (0.29 sec)
-
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/interfaces.go
// HasSynced returns true if the source has completed its initial sync. HasSynced() bool } // Dispatcher dispatches evaluates an admission request against the currently // active hooks returned by the source. type Dispatcher[H Hook] interface { // Dispatch a request to the policies. Dispatcher may choose not to // call a hook, either because the rules of the hook does not match, or
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 13 21:06:39 UTC 2024 - 2.3K bytes - Viewed (0) -
src/runtime/debugcall.go
}) } func debugCallWrap2(dispatch uintptr) { // Call the dispatch function and trap panics. var dispatchF func() dispatchFV := funcval{dispatch} *(*unsafe.Pointer)(unsafe.Pointer(&dispatchF)) = noescape(unsafe.Pointer(&dispatchFV)) var ok bool defer func() { if !ok { err := recover() debugCallPanicked(err) } }() dispatchF() ok = true
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 05 20:50:21 UTC 2024 - 7.1K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/MessageHub.java
rejectedMessageListener = DISCARD; } Dispatch<Object> dispatch; if (handler instanceof Dispatch) { dispatch = Cast.uncheckedNonnullCast(handler); } else { dispatch = DISCARD; } BoundedDispatch<Object> boundedDispatch; if (dispatch instanceof BoundedDispatch) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 16.2K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/client/ReportStatusDispatcherTest.groovy
def dispatcher = new ReportStatusDispatcher() def connection = Mock(Connection) def "ignores failed dispatch and does not receive"() { given: def message = new ReportStatus(UUID.randomUUID(), "TOKEN".bytes) connection.dispatch(message) >> { throw new RuntimeException("Cannot dispatch") } when: dispatcher.dispatch(connection, message) then:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 1.7K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/client/StopDispatcherTest.groovy
public class StopDispatcherTest extends Specification { def dispatcher = new StopDispatcher() def connection = Mock(Connection) def "ignores failed dispatch and does not receive"() { given: def message = new Stop(UUID.randomUUID()) connection.dispatch(message) >> { throw new RuntimeException("Cannot dispatch") } when: dispatcher.dispatch(connection, message) then:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 1.6K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/event/BroadcastDispatch.java
} @Override public void dispatch(MethodInvocation message) { } } private static class SingletonDispatch<T> extends BroadcastDispatch<T> { private final Object handler; private final Dispatch<MethodInvocation> dispatch; SingletonDispatch(Class<T> type, Object handler, Dispatch<MethodInvocation> dispatch) { super(type);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 09 13:00:00 UTC 2024 - 12.3K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/dispatch/FailureHandlingDispatchTest.groovy
*/ package org.gradle.internal.dispatch import spock.lang.Specification class FailureHandlingDispatchTest extends Specification { final Dispatch<String> target = Mock() final DispatchFailureHandler<String> handler = Mock() final FailureHandlingDispatch<String> dispatch = new FailureHandlingDispatch<String>(target, handler) def "dispatches message to target"() { when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 1.8K bytes - Viewed (0) -
mockwebserver/src/test/java/mockwebserver3/CustomDispatcherTest.kt
val requestsMade = mutableListOf<RecordedRequest>() val dispatcher: Dispatcher = object : Dispatcher() { override fun dispatch(request: RecordedRequest): MockResponse { requestsMade.add(request) return MockResponse() } } assertThat(requestsMade.size).isEqualTo(0) mockWebServer.dispatcher = dispatcher val url = mockWebServer.url("/").toUrl()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3.3K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/event/DefaultListenerManager.java
return result; } private void endNotification(List<Dispatch<MethodInvocation>> dispatchers) { for (Dispatch<MethodInvocation> dispatcher : dispatchers) { if (dispatcher instanceof ListenerDetails) { ListenerDetails listener = (ListenerDetails) dispatcher; listener.endNotification(); } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 10:09:43 UTC 2024 - 18.3K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/Connection.java
*/ package org.gradle.internal.remote.internal; import org.gradle.internal.concurrent.Stoppable; import org.gradle.internal.dispatch.Dispatch; import org.gradle.internal.dispatch.Receive; /** * <p>A messaging endpoint which allows push-style dispatch and pull-style receive. * * <p>Implementations are not guaranteed to be completely thread-safe. * However, the implementations: * <ul>
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 05 19:36:14 UTC 2023 - 1.4K bytes - Viewed (0)