- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 215 for dispatchTo (0.14 sec)
-
platforms/ide/tooling-api/src/test/groovy/org/gradle/tooling/internal/consumer/async/DefaultAsyncConsumerActionExecutorTest.groovy
} def "runs action asynchronously"() { when: async { connection.run(action, handler) instant.dispatched } then: 1 * actionExecuter.run(action) >> { thread.blockUntil.dispatched instant.actionStarted return "result" } 1 * handler.onComplete("result") >> { instant.resultReceived
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 2.4K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/classpath/InstrumentedClosuresTracker.java
* to the current closures chain and can potentially be intercepted. The implementation must ensure that all the closures in the scope are processed in a way that * ensures call interception if a call is dispatched to them. */ @NonNullApi public interface InstrumentedClosuresTracker {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Aug 11 12:31:52 UTC 2023 - 1.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/LoomTest.kt
@BeforeEach fun setUp(server: MockWebServer) { platform.assumeLoom() this.server = server client = clientTestRule.newClientBuilder() .dispatcher(Dispatcher(newVirtualThreadPerTaskExecutor())) .build() } private fun newVirtualThreadPerTaskExecutor(): ExecutorService {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java
queue.enqueue(incrementingEvent(counters, listener, 3)); queue.enqueue(incrementingEvent(counters, listener, 4)); assertEquals(0, counters.size()); queue.dispatch(); assertEquals(multiset(listener, 4), counters); } public void testEnqueueAndDispatch_multipleListeners() { Object listener1 = new Object(); ListenerCallQueue<Object> queue = new ListenerCallQueue<>();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Feb 09 22:57:07 UTC 2022 - 8.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java
queue.enqueue(incrementingEvent(counters, listener, 3)); queue.enqueue(incrementingEvent(counters, listener, 4)); assertEquals(0, counters.size()); queue.dispatch(); assertEquals(multiset(listener, 4), counters); } public void testEnqueueAndDispatch_multipleListeners() { Object listener1 = new Object(); ListenerCallQueue<Object> queue = new ListenerCallQueue<>();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Feb 09 22:57:07 UTC 2022 - 8.2K bytes - Viewed (0) -
platforms/ide/tooling-api/src/test/groovy/org/gradle/tooling/internal/consumer/DefaultPhasedBuildActionExecuterTest.groovy
start { thread.blockUntil.dispatched instant.resultAvailable adaptedHandler.onComplete(null) } } handler.onComplete(null) >> { instant.resultReceived } when: async { executer.run(handler) instant.dispatched thread.blockUntil.resultReceived }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/Locks.kt
import kotlin.contracts.InvocationKind import kotlin.contracts.contract import okhttp3.Dispatcher import okhttp3.internal.http2.Http2Connection import okhttp3.internal.http2.Http2Stream import okhttp3.internal.http2.Http2Writer /** * Centralisation of central locks according to docs/contribute/concurrency.md */ internal object Locks { inline fun <T> Dispatcher.withLock(action: () -> T): T {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 2.1K bytes - Viewed (0) -
platforms/ide/tooling-api/src/test/groovy/org/gradle/tooling/internal/consumer/DefaultBuildActionExecuterTest.groovy
start { thread.blockUntil.dispatched instant.resultAvailable wrappedHandler.onComplete(result) } } handler.onComplete(result) >> { instant.resultReceived } when: async { executer.run(handler) instant.dispatched thread.blockUntil.resultReceived }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 6.1K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/RemoteConnection.java
*/ public interface RemoteConnection<T> extends Connection<T> { /** * {@inheritDoc} * * @throws MessageIOException On failure to dispatch the message to the peer. */ @Override void dispatch(T message) throws MessageIOException; void flush() throws MessageIOException; /** * {@inheritDoc}
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 1.4K bytes - Viewed (0) -
okhttp-coroutines/README.md
call.executeAsync().use { response -> withContext(Dispatchers.IO) { println(response.body?.string()) } } ``` This is implemented using `suspendCancellableCoroutine` but uses the standard Dispatcher in OkHttp. This means that by default Kotlin's Dispatchers are not used. Cancellation if implemented sensibly in both directions. Cancelling a coroutine scope, will cancel the call.
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Nov 09 15:47:27 UTC 2023 - 609 bytes - Viewed (0)