- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for BoundedDispatch (0.28 sec)
-
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/dispatch/BoundedDispatch.java
*/ package org.gradle.internal.dispatch; /** * A sink for a bounded stream of messages. * * <p>Implementations are not required to be thread-safe. */ public interface BoundedDispatch<T> extends Dispatch<T>, StreamCompletion { /** * Signals the end of the stream of messages. No further messages should be dispatched using the {@link Dispatch#dispatch(Object)} method after this method is called. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 1K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/MessageHubBackedObjectConnection.java
import org.gradle.internal.concurrent.CompositeStoppable; import org.gradle.internal.concurrent.ExecutorFactory; import org.gradle.internal.concurrent.ThreadSafe; import org.gradle.internal.dispatch.BoundedDispatch; import org.gradle.internal.dispatch.Dispatch; import org.gradle.internal.dispatch.MethodInvocation; import org.gradle.internal.dispatch.ProxyDispatchAdapter; import org.gradle.internal.dispatch.ReflectionDispatch;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 7.5K bytes - Viewed (0)