- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 215 for dispatchTo (0.17 sec)
-
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) -
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) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/queue/MultiEndPointQueue.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; import java.util.ArrayDeque; import java.util.ArrayList;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 3.9K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/client/DaemonClientConnection.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 30 06:43:50 UTC 2024 - 4.2K bytes - Viewed (0) -
platforms/core-runtime/logging/src/main/java/org/gradle/internal/logging/sink/LogEventDispatcher.java
if (event.getLogLevel() == null) { dispatch(event, stdoutChain); dispatch(event, stderrChain); } else if (event.getLogLevel() == LogLevel.ERROR) { dispatch(event, stderrChain); } else { dispatch(event, stdoutChain); } } protected void dispatch(OutputEvent event, OutputEventListener listener) { if (listener != null) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:05:18 UTC 2023 - 1.7K bytes - Viewed (0)