- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for queuedCalls (0.09 sec)
-
okhttp/src/test/java/okhttp3/DispatcherTest.kt
.containsExactlyInAnyOrder(a1, a2) assertThat(dispatcher.queuedCalls()).isEmpty() // Cancel some calls. That doesn't impact running or queued. a2.cancel() a3.cancel() assertThat(dispatcher.runningCalls()) .containsExactlyInAnyOrder(a1, a2) assertThat(dispatcher.queuedCalls()).isEmpty() // Let the calls finish. waiting.countDown() t1.join()
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Fri Apr 05 03:30:42 UTC 2024 - 12.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Dispatcher.kt
val isRunning = promoteAndExecute() if (!isRunning && idleCallback != null) { idleCallback.run() } } /** Returns a snapshot of the calls currently awaiting execution. */ fun queuedCalls(): List<Call> = this.withLock { return Collections.unmodifiableList(readyAsyncCalls.map { it.call }) } /** Returns a snapshot of the calls currently being executed. */
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Thu Jun 20 14:10:53 UTC 2024 - 9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/KotlinSourceModernTest.kt
dispatcher.maxRequestsPerHost = 0 val executorService: ExecutorService = dispatcher.executorService dispatcher.idleCallback = Runnable { ({ TODO() })() } val queuedCalls: List<Call> = dispatcher.queuedCalls() val runningCalls: List<Call> = dispatcher.runningCalls() val queuedCallsCount: Int = dispatcher.queuedCallsCount() val runningCallsCount: Int = dispatcher.runningCallsCount()
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Apr 01 14:21:25 UTC 2024 - 46.5K bytes - Viewed (0) -
docs/changelogs/changelog_3x.md
The API to cancel calls by tag has been removed and replaced with a more general mechanism. The dispatcher now exposes all in-flight calls via its `runningCalls()` and `queuedCalls()` methods. You can write code that selects calls by tag, host, or whatever, and invokes `Call.cancel()` on the ones that are no longer necessary.
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sun Feb 06 14:55:54 UTC 2022 - 50.8K bytes - Viewed (0) -
okhttp/api/okhttp.api
public final fun getIdleCallback ()Ljava/lang/Runnable; public final fun getMaxRequests ()I public final fun getMaxRequestsPerHost ()I public final fun queuedCalls ()Ljava/util/List; public final fun queuedCallsCount ()I public final fun runningCalls ()Ljava/util/List; public final fun runningCallsCount ()I public final fun setIdleCallback (Ljava/lang/Runnable;)V
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Apr 15 13:41:01 UTC 2024 - 70.2K bytes - Viewed (0)