- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 412 for dispatchTo (0.23 sec)
-
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/client/DaemonCancelForwarder.java
public DaemonCancelForwarder(final Dispatch<? super Cancel> dispatch, BuildCancellationToken cancellationToken) { this.cancellationToken = cancellationToken; cancellationCallback = new Runnable() { @Override public void run() { LOGGER.info("Request daemon to cancel build..."); dispatch.dispatch(new Cancel()); } }; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 1.8K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/queue/QueueInitializer.java
* See the License for the specific language governing permissions and * limitations under the License. */ package org.gradle.internal.remote.internal.hub.queue; import org.gradle.internal.dispatch.Dispatch; import org.gradle.internal.remote.internal.hub.protocol.EndOfStream; import org.gradle.internal.remote.internal.hub.protocol.InterHubMessage; public class QueueInitializer { private EndOfStream endOfStream;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 1.4K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/actor/internal/DefaultActorFactorySpec.groovy
* limitations under the License. */ package org.gradle.internal.actor.internal import org.gradle.internal.concurrent.ThreadSafe import org.gradle.internal.dispatch.DispatchException import org.gradle.internal.dispatch.MethodInvocation import org.gradle.test.fixtures.concurrent.ConcurrentSpec class DefaultActorFactorySpec extends ConcurrentSpec { private final TargetObject target = Mock()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 8.1K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/event/ListenerBroadcast.java
* limitations under the License. */ package org.gradle.internal.event; import org.gradle.api.Action; import org.gradle.internal.dispatch.Dispatch; import org.gradle.internal.dispatch.MethodInvocation; import org.gradle.internal.dispatch.ProxyDispatchAdapter; import java.util.Collection; /** * <p>Manages a set of listeners of type T. Provides an implementation of T which can be used to broadcast to all
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 4.5K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/client/DaemonClientTest.groovy
return false } 1 * connection.dispatch({ it instanceof Build }) 2 * connection.receive() >>> [Stub(BuildStarted), new Failure(new DaemonStoppedException())] 1 * connection.dispatch({ it instanceof Cancel }) 1 * connection.dispatch({ it instanceof CloseInput }) 1 * connection.dispatch({ it instanceof Finished }) 1 * cancellationToken.cancellationRequested >> true
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:54:56 UTC 2024 - 10K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/listener/ClosureBackedMethodInvocationDispatch.java
* limitations under the License. */ package org.gradle.listener; import groovy.lang.Closure; import org.gradle.internal.dispatch.Dispatch; import org.gradle.internal.dispatch.MethodInvocation; import java.util.Arrays; public class ClosureBackedMethodInvocationDispatch implements Dispatch<MethodInvocation> { private final String methodName; private final Closure closure;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 09 12:43:02 UTC 2024 - 2.2K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/internal/classpath/BasicCallInterceptionTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Nov 15 09:44:54 UTC 2023 - 8.8K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/MessageHubBackedObjectConnection.java
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; import org.gradle.internal.dispatch.StreamCompletion; import org.gradle.internal.exceptions.DefaultMultiCauseException;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 7.5K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/testFixtures/groovy/org/gradle/internal/actor/TestActorFactory.java
*/ package org.gradle.internal.actor; import org.gradle.internal.concurrent.ThreadSafe; import org.gradle.internal.dispatch.DispatchException; import org.gradle.internal.dispatch.MethodInvocation; import org.gradle.internal.dispatch.ProxyDispatchAdapter; import org.gradle.internal.dispatch.ReflectionDispatch; public class TestActorFactory implements ActorFactory { @Override public Actor createActor(Object target) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 1.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_context.go
// to priority and fairness dispatcher. func initializationSignalFrom(ctx context.Context) (InitializationSignal, bool) { signal, ok := ctx.Value(priorityAndFairnessInitializationSignalKey).(InitializationSignal) return signal, ok && signal != nil } // WatchInitialized sends a signal to priority and fairness dispatcher // that a given watch request has already been initialized.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 14 14:39:15 UTC 2021 - 2.9K bytes - Viewed (0)