- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for ProxyDispatchAdapter (0.45 sec)
-
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/dispatch/ProxyDispatchAdapter.java
import java.lang.reflect.Proxy; import java.util.ArrayList; import java.util.List; /** * Adapts from interface T to a {@link Dispatch} */ public class ProxyDispatchAdapter<T> { private final Class<T> type; private final T source; public ProxyDispatchAdapter(Dispatch<? super MethodInvocation> dispatch, Class<T> type, Class<?>... extraTypes) { this.type = type; List<Class<?>> types = new ArrayList<Class<?>>();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 13:09:37 UTC 2024 - 3.5K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/dispatch/ProxyDispatchAdapterTest.groovy
} def proxyIsEqualWhenItHasTheSameTypeAndDispatch() { def other = new ProxyDispatchAdapter<ProxyTest>(dispatch, ProxyTest.class) def differentType = new ProxyDispatchAdapter<Runnable>(dispatch, Runnable.class) def differentDispatch = new ProxyDispatchAdapter<ProxyTest>(Mock(Dispatch.class), ProxyTest.class) expect: ProxyTest proxy = adapter.getSource()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 2.3K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/dispatch/ContextClassLoaderProxy.java
*/ public class ContextClassLoaderProxy<T> { private final ProxyDispatchAdapter<T> adapter; /** * Creates a proxy which dispatches to the given target object. */ public ContextClassLoaderProxy(Class<T> type, T target, ClassLoader contextClassLoader) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 13:09:37 UTC 2024 - 1.2K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/event/ListenerBroadcast.java
*/ 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 listeners.</p> *
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/messaging/src/main/java/org/gradle/internal/actor/internal/DefaultActorFactory.java
import org.gradle.internal.dispatch.ExceptionTrackingFailureHandler; import org.gradle.internal.dispatch.FailureHandlingDispatch; import org.gradle.internal.dispatch.MethodInvocation; import org.gradle.internal.dispatch.ProxyDispatchAdapter; import org.gradle.internal.dispatch.ReflectionDispatch; import org.slf4j.LoggerFactory; import java.util.IdentityHashMap; /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 13:09:37 UTC 2024 - 6.3K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/testFixtures/groovy/org/gradle/internal/actor/TestActorFactory.java
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) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/MessageHubBackedObjectConnection.java
throw new GradleException("Cannot add outgoing message transmitter after connection established."); } methodParamClassLoaders.add(type.getClassLoader()); ProxyDispatchAdapter<T> adapter = new ProxyDispatchAdapter<T>(hub.getOutgoing(type.getName(), MethodInvocation.class), type, ThreadSafe.class); return adapter.getSource(); } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 7.5K bytes - Viewed (0)