- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 64 for dispatchTo (0.12 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) -
mockwebserver/src/main/kotlin/mockwebserver3/Dispatcher.kt
* request bodies. */ open fun peek(): MockResponse { return MockResponse(socketPolicy = KeepOpen) } /** * Release any resources held by this dispatcher. Any requests that are currently being dispatched * should return immediately. Responses returned after shutdown will not be transmitted: their * socket connections have already been closed. */ open fun shutdown() {}
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Tue Jan 23 14:31:42 UTC 2024 - 1.7K 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) -
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) -
mockwebserver/src/main/kotlin/mockwebserver3/QueueDispatcher.kt
import java.util.concurrent.LinkedBlockingQueue import java.util.logging.Logger import okhttp3.ExperimentalOkHttpApi /** * Default dispatcher that processes a script of responses. Populate the script by calling [enqueueResponse]. */ @ExperimentalOkHttpApi open class QueueDispatcher : Dispatcher() { protected val responseQueue: BlockingQueue<MockResponse> = LinkedBlockingQueue() private var failFastResponse: MockResponse? = null
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Tue Jan 23 14:31:42 UTC 2024 - 3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/plugin.go
return nil } func (c *Plugin[H]) Dispatch( ctx context.Context, a admission.Attributes, o admission.ObjectInterfaces, ) (err error) { if !c.enabled { return nil } else if c.shouldIgnoreResource(a) { return nil } else if !c.WaitForReady() { return admission.NewForbidden(a, fmt.Errorf("not yet ready to handle request")) } return c.dispatcher.Dispatch(ctx, a, o, c.source.Hooks()) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 05 19:11:10 UTC 2024 - 6.6K 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)