- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 330 for dispatchTo (0.15 sec)
-
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/dispatch/AsyncDispatchTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 05 19:36:14 UTC 2023 - 6.5K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/dispatch/AsyncDispatch.java
state = State.Init; if (dispatch != null) { dispatchTo(dispatch); } } /** * Starts dispatching messages to the given handler. The handler does not need to be thread-safe. */ public void dispatchTo(final Dispatch<? super T> dispatch) { final InterruptibleRunnable dispatcher = new InterruptibleRunnable(new Runnable() { @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Dec 11 13:37:56 UTC 2023 - 6.7K bytes - Viewed (0) -
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) -
android/guava/src/com/google/common/eventbus/Dispatcher.java
static Dispatcher legacyAsync() { return new LegacyAsyncDispatcher(); } /** * Returns a dispatcher that dispatches events to subscribers immediately as they're posted * without using an intermediate queue to change the dispatch order. This is effectively a * depth-first dispatch order, vs. breadth-first when using a queue. */ static Dispatcher immediate() { return ImmediateDispatcher.INSTANCE; }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Dec 15 19:31:54 UTC 2023 - 7.3K bytes - Viewed (0) -
guava/src/com/google/common/eventbus/Dispatcher.java
static Dispatcher legacyAsync() { return new LegacyAsyncDispatcher(); } /** * Returns a dispatcher that dispatches events to subscribers immediately as they're posted * without using an intermediate queue to change the dispatch order. This is effectively a * depth-first dispatch order, vs. breadth-first when using a queue. */ static Dispatcher immediate() { return ImmediateDispatcher.INSTANCE; }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Dec 15 19:31:54 UTC 2023 - 7.3K 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) -
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) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/dispatch/Dispatch.java
* limitations under the License. */ package org.gradle.internal.dispatch; /** * A general purpose sink for a stream of messages. * * <p>Implementations are not required to be thread-safe. */ public interface Dispatch<T> { /** * Dispatches the next message. Blocks until the messages has been accepted but generally does not wait for the
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 05 19:36:14 UTC 2023 - 1.1K bytes - Viewed (0)