- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 181 for dispatchTo (0.18 sec)
-
platforms/core-runtime/messaging/src/integTest/groovy/org/gradle/internal/remote/internal/hub/MessageHubIntegrationTest.groovy
then: 1 * clientHandler.dispatch("message 1") >> { clientDispatch.dispatch("[message 1]") } 1 * clientHandler.dispatch("message 2") >> { clientDispatch.dispatch("[message 2]") } 1 * clientHandler.dispatch("message 3") 1 * clientHandler.dispatch("message 4") 1 * clientHandler.dispatch("message 5") 1 * clientHandler.dispatch("message 6")
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 9K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/eventspy/internal/EventSpyRepositoryListener.java
private final EventSpyDispatcher dispatcher; private final RepositoryListener delegate; EventSpyRepositoryListener(EventSpyDispatcher dispatcher, RepositoryListener delegate) { this.dispatcher = dispatcher; this.delegate = delegate; } @Override public void artifactDeployed(RepositoryEvent event) { dispatcher.onEvent(event); delegate.artifactDeployed(event);
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Nov 22 13:26:01 UTC 2022 - 4.3K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/actor/internal/DefaultActorFactory.java
import org.gradle.internal.dispatch.AsyncDispatch; import org.gradle.internal.dispatch.Dispatch; import org.gradle.internal.dispatch.DispatchException; import org.gradle.internal.dispatch.ExceptionTrackingFailureHandler; import org.gradle.internal.dispatch.FailureHandlingDispatch; import org.gradle.internal.dispatch.MethodInvocation; import org.gradle.internal.dispatch.ProxyDispatchAdapter;
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/main/java/org/gradle/internal/dispatch/ContextClassLoaderDispatch.java
* limitations under the License. */ package org.gradle.internal.dispatch; public class ContextClassLoaderDispatch<T> implements Dispatch<T> { private final Dispatch<? super T> dispatch; private final ClassLoader contextClassLoader; public ContextClassLoaderDispatch(Dispatch<? super T> dispatch, ClassLoader contextClassLoader) { this.dispatch = dispatch; this.contextClassLoader = contextClassLoader; }
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/remote/internal/hub/queue/MultiEndPointQueueTest.groovy
and: queue.dispatch(message1) queue.dispatch(message2) queue.dispatch(message3) when: def endpoint = queue.newEndpoint() def messages = [] endpoint.take(messages) then: messages == [message1, message2, message3] } def "does not dispatch anything to endpoint that has stopped"() { given:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 4.3K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/client/DaemonStopClientTest.groovy
1 * connection.dispatch({it instanceof Stop}) 1 * connection.receive() >> new Success(null) 1 * connection.dispatch({it instanceof Finished}) 1 * connection.stop() 1 * connection2.dispatch({it instanceof Stop}) 1 * connection2.receive() >> new Success(null) 1 * connection2.dispatch({it instanceof Finished}) 1 * connection2.stop()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 5.7K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/dispatch/ExceptionTrackingFailureHandlerTest.groovy
when: dispatch.dispatchFailed("message", failure) dispatch.stop() then: def e = thrown(DispatchException) e.cause == failure 0 * logger._ } def logsAnySubsequentFailures() { RuntimeException failure1 = new RuntimeException() RuntimeException failure2 = new RuntimeException('broken2') when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 1.8K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/event/AbstractBroadcastDispatch.java
case 1: dispatch(invocation, dispatchers.get(0)); break; default: dispatch(invocation, dispatchers.iterator()); break; } } /** * Dispatch an invocation to multiple handlers. */ private void dispatch(MethodInvocation invocation, Iterator<? extends Dispatch<MethodInvocation>> handlers) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 13:09:37 UTC 2024 - 4.2K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/dispatch/ProxyDispatchAdapterTest.groovy
*/ package org.gradle.internal.dispatch import spock.lang.Specification import static org.gradle.util.Matchers.strictlyEquals class ProxyDispatchAdapterTest extends Specification { private final Dispatch<MethodInvocation> dispatch = Mock() private final ProxyDispatchAdapter<ProxyTest> adapter = new ProxyDispatchAdapter<ProxyTest>(dispatch, ProxyTest.class) def proxyForwardsToDispatch() {
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/launcher/src/test/groovy/org/gradle/launcher/daemon/client/DaemonCancelForwarderTest.groovy
import org.gradle.internal.dispatch.Dispatch import org.gradle.util.ConcurrentSpecification import java.util.concurrent.LinkedBlockingQueue import java.util.concurrent.TimeUnit class DaemonCancelForwarderTest extends ConcurrentSpecification { def cancellationToken = new DefaultBuildCancellationToken() def received = new LinkedBlockingQueue() def dispatch = { received << it } as Dispatch
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 1.8K bytes - Viewed (0)