- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 412 for dispatchTo (0.18 sec)
-
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/event/BroadcastDispatch.java
} @Override public void dispatch(MethodInvocation message) { } } private static class SingletonDispatch<T> extends BroadcastDispatch<T> { private final Object handler; private final Dispatch<MethodInvocation> dispatch; SingletonDispatch(Class<T> type, Object handler, Dispatch<MethodInvocation> dispatch) { super(type);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 09 13:00:00 UTC 2024 - 12.3K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/dispatch/FailureHandlingDispatchTest.groovy
*/ package org.gradle.internal.dispatch import spock.lang.Specification class FailureHandlingDispatchTest extends Specification { final Dispatch<String> target = Mock() final DispatchFailureHandler<String> handler = Mock() final FailureHandlingDispatch<String> dispatch = new FailureHandlingDispatch<String>(target, handler) def "dispatches message to target"() { 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) -
mockwebserver/src/test/java/mockwebserver3/CustomDispatcherTest.kt
val requestsMade = mutableListOf<RecordedRequest>() val dispatcher: Dispatcher = object : Dispatcher() { override fun dispatch(request: RecordedRequest): MockResponse { requestsMade.add(request) return MockResponse() } } assertThat(requestsMade.size).isEqualTo(0) mockWebServer.dispatcher = dispatcher val url = mockWebServer.url("/").toUrl()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3.3K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/event/DefaultListenerManager.java
return result; } private void endNotification(List<Dispatch<MethodInvocation>> dispatchers) { for (Dispatch<MethodInvocation> dispatcher : dispatchers) { if (dispatcher instanceof ListenerDetails) { ListenerDetails listener = (ListenerDetails) dispatcher; listener.endNotification(); } }
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/messaging/src/main/java/org/gradle/internal/remote/internal/Connection.java
*/ package org.gradle.internal.remote.internal; import org.gradle.internal.concurrent.Stoppable; import org.gradle.internal.dispatch.Dispatch; import org.gradle.internal.dispatch.Receive; /** * <p>A messaging endpoint which allows push-style dispatch and pull-style receive. * * <p>Implementations are not guaranteed to be completely thread-safe. * However, the implementations: * <ul>
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 05 19:36:14 UTC 2023 - 1.4K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/client/DaemonClientConnectionTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 3.8K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/dispatch/BoundedDispatch.java
*/ package org.gradle.internal.dispatch; /** * A sink for a bounded stream of messages. * * <p>Implementations are not required to be thread-safe. */ public interface BoundedDispatch<T> extends Dispatch<T>, StreamCompletion { /** * Signals the end of the stream of messages. No further messages should be dispatched using the {@link Dispatch#dispatch(Object)} method after this method is called. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 1K bytes - Viewed (0) -
mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/KotlinSourceModernTest.kt
mockWebServer.start(0) mockWebServer.start(InetAddress.getLocalHost(), 0) mockWebServer.shutdown() var dispatcher: Dispatcher = mockWebServer.dispatcher dispatcher = mockWebServer.dispatcher mockWebServer.dispatcher = QueueDispatcher() mockWebServer.dispatcher = QueueDispatcher() mockWebServer.close() } @Test @Ignore fun pushPromise() {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 7.3K bytes - Viewed (0) -
mockwebserver/README.md
``` #### Dispatcher By default MockWebServer uses a queue to specify a series of responses. Use a Dispatcher (`import okhttp3.mockwebserver.Dispatcher`) to handle requests using another policy. One natural policy is to dispatch on the request path. You can, for example, filter the request instead of using `server.enqueue()`. ```java final Dispatcher dispatcher = new Dispatcher() { @Override
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Dec 17 15:34:10 UTC 2023 - 5K bytes - Viewed (0) -
mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/DeprecationBridge.kt
import mockwebserver3.SocketPolicy.StallSocketAtStart internal fun Dispatcher.wrap(): mockwebserver3.Dispatcher { if (this is QueueDispatcher) return this.delegate val delegate = this return object : mockwebserver3.Dispatcher() { override fun dispatch(request: mockwebserver3.RecordedRequest): mockwebserver3.MockResponse { return delegate.dispatch(request.unwrap()).wrap() }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 4.6K bytes - Viewed (0)