- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 797 for Dispatch (0.19 sec)
-
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/dispatch/Dispatch.java
* See the License for the specific language governing permissions and * limitations under the License. */ package org.gradle.internal.dispatch; /** * A general purpose sink for a stream of messages. * * <p>Implementations are not required to be thread-safe. */ public interface Dispatch<T> { /** * Dispatches the next message. Blocks until the messages has been accepted but generally does not wait for the
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 05 19:36:14 UTC 2023 - 1.1K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/event/BroadcastDispatchTest.groovy
expect: def dispatch1 = BroadcastDispatch.empty(TestListener) dispatch1.removeAll([]).is(dispatch1) dispatch1.removeAll([listener2, listener3]).is(dispatch1) def dispatch2 = dispatch1.add(listener1) dispatch2.removeAll([]).is(dispatch2) dispatch2.removeAll([listener2, listener3]).is(dispatch2) def dispatch3 = dispatch2.add(listener2)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 14.9K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/event/ListenerBroadcastTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 9.4K bytes - Viewed (0) -
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) -
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/dispatch/FailureHandlingDispatchTest.groovy
when: dispatch.dispatch("message") then: 1 * target.dispatch("message") } def "notifies handler on failure"() { def failure = new RuntimeException() when: dispatch.dispatch("message") then: 1 * target.dispatch("message") >> { throw failure } 1 * handler.dispatchFailed("message", failure) }
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/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/messaging/src/main/java/org/gradle/internal/event/DefaultListenerManager.java
package org.gradle.internal.event; import com.google.common.collect.ImmutableList; import org.gradle.internal.Cast; 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.service.scopes.EventScope; import org.gradle.internal.service.scopes.ListenerService;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 10:09:43 UTC 2024 - 18.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)