- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 116 for dispatchTo (0.3 sec)
-
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/event/BroadcastDispatchTest.groovy
expect: def dispatch1 = BroadcastDispatch.empty(TestListener) dispatch1.removeAll([]).is(dispatch1) dispatch1.removeAll([listener2, listener3]).is(dispatch1) def dispatch2 = dispatch1.add(listener1) dispatch2.removeAll([]).is(dispatch2) dispatch2.removeAll([listener2, listener3]).is(dispatch2) def dispatch3 = dispatch2.add(listener2)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 14.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/validating/dispatcher.go
"k8s.io/apiserver/pkg/warning" "k8s.io/klog/v2" ) type dispatcher struct { matcher generic.PolicyMatcher authz authorizer.Authorizer } var _ generic.Dispatcher[PolicyHook] = &dispatcher{} func NewDispatcher( authorizer authorizer.Authorizer, matcher generic.PolicyMatcher, ) generic.Dispatcher[PolicyHook] { return &dispatcher{ matcher: matcher, authz: authorizer, } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 14.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/validating/dispatcher.go
) type validatingDispatcher struct { cm *webhookutil.ClientManager plugin *Plugin } func newValidatingDispatcher(p *Plugin) func(cm *webhookutil.ClientManager) generic.Dispatcher { return func(cm *webhookutil.ClientManager) generic.Dispatcher { return &validatingDispatcher{cm, p} } } var _ generic.VersionedAttributeAccessor = &versionedAttributeAccessor{} type versionedAttributeAccessor struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 23 20:24:12 UTC 2023 - 13K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/mutating/dispatcher.go
) type mutatingDispatcher struct { cm *webhookutil.ClientManager plugin *Plugin } func newMutatingDispatcher(p *Plugin) func(cm *webhookutil.ClientManager) generic.Dispatcher { return func(cm *webhookutil.ClientManager) generic.Dispatcher { return &mutatingDispatcher{cm, p} } } var _ generic.VersionedAttributeAccessor = &versionedAttributeAccessor{} type versionedAttributeAccessor struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 19.6K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/remote/internal/hub/MessageHubTest.groovy
dispatcher2 != null dispatcher1 != dispatcher2 } def "can dispatch outgoing messages"() { given: def dispatcher = hub.getOutgoing("channel", String) expect: dispatcher.dispatch("message 1") dispatcher.dispatch("message 2") } def "outgoing messages are dispatched asynchronously to connection"() { RemoteConnection<InterHubMessage> outgoing = Mock()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 21.8K 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/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/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) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset.go
// win in the case that the virtual finish times are the same qs.robinIndex = minIndex if minQueue.nextDispatchR < oldestReqFromMinQueue.arrivalR { klog.ErrorS(errors.New("dispatch before arrival"), "Inconceivable!", "QS", qs.qCfg.Name, "queue", minQueue.index, "dispatchR", minQueue.nextDispatchR, "request", oldestReqFromMinQueue) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 04 16:59:21 UTC 2024 - 42.4K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
/** * The dispatcher used to respond to HTTP requests. The default dispatcher is a [QueueDispatcher], * which serves a fixed sequence of responses from a [queue][enqueue]. * * Other dispatchers can be configured. They can vary the response based on timing or the content * of the request. */ var dispatcher: Dispatcher = QueueDispatcher() private var portField: Int = -1
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Mar 31 17:16:15 UTC 2024 - 37.4K bytes - Viewed (0)