- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 130 for dispatchTo (0.17 sec)
-
platforms/core-runtime/logging/src/main/java/org/gradle/internal/logging/console/GlobalUserInputReceiver.java
* The instance is not injected directly into this service as the instance will be constructed in some other scope. * </p> */ void dispatchTo(UserInputReceiver userInput); /** * Discards the current {@link UserInputReceiver} instance used by this service. */ void stopDispatching();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 30 05:02:18 UTC 2024 - 2.1K bytes - Viewed (0) -
platforms/core-runtime/logging/src/main/java/org/gradle/internal/logging/console/DefaultUserInputReceiver.java
if (userInput == null) { throw new IllegalStateException("User input has not been initialized."); } return userInput; } @Override public void dispatchTo(UserInputReceiver userInput) { if (!delegate.compareAndSet(null, userInput)) { throw new IllegalStateException("User input has already been initialized."); } } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 12:11:05 UTC 2024 - 3.3K bytes - Viewed (0) -
platforms/core-runtime/client-services/src/main/java/org/gradle/internal/daemon/client/clientinput/DaemonClientInputForwarder.java
userInput.dispatchTo(forwarder); } @Override public void stop() { userInput.stopDispatching(); forwarder.stop(); executor.shutdown(); } private static class ForwardingUserInput implements UserInputReceiver { private final Dispatch<? super InputMessage> dispatch; private final BufferedReader reader;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:53:31 UTC 2024 - 5.8K 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) -
okhttp/src/main/kotlin/okhttp3/Dispatcher.kt
import okhttp3.internal.threadFactory /** * Policy on when async requests are executed. * * Each dispatcher uses an [ExecutorService] to run calls internally. If you supply your own * executor, it should be able to run [the configured maximum][maxRequests] number of calls * concurrently. */ class Dispatcher() { internal val lock: ReentrantLock = ReentrantLock() /**
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 9K 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) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/generic/webhook.go
*admission.Handler sourceFactory sourceFactory hookSource Source clientManager *webhookutil.ClientManager namespaceMatcher *namespace.Matcher objectMatcher *object.Matcher dispatcher Dispatcher filterCompiler cel.FilterCompiler authorizer authorizer.Authorizer } var ( _ genericadmissioninit.WantsExternalKubeClientSet = &Webhook{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 22:07:40 UTC 2024 - 9.3K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/api/DaemonConnection.java
*/ void onCancel(@Nullable Runnable handler); /** * Dispatches a daemon unavailable message to the client. */ void daemonUnavailable(DaemonUnavailable unavailable); /** * Dispatches a build started message to the client. */ void buildStarted(BuildStarted buildStarted); /** * Dispatches a log event message to the client. */ void logEvent(OutputEvent logEvent);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:51:37 UTC 2024 - 3.8K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/dispatch/ContextClassLoaderProxy.java
* limitations under the License. */ package org.gradle.internal.dispatch; /** * Creates a proxy object which sets the context ClassLoader when invoking methods on the target object. */ public class ContextClassLoaderProxy<T> { private final ProxyDispatchAdapter<T> adapter; /** * Creates a proxy which dispatches to the given target object. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 13:09:37 UTC 2024 - 1.2K 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)