- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for CancelCall (0.08 sec)
-
samples/guide/src/main/java/okhttp3/recipes/kt/CancelCall.kt
*/ package okhttp3.recipes.kt import java.io.IOException import java.util.concurrent.Executors import java.util.concurrent.TimeUnit import okhttp3.OkHttpClient import okhttp3.Request class CancelCall { private val executor = Executors.newScheduledThreadPool(1) private val client = OkHttpClient() fun run() { val request = Request.Builder()
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 1.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt
return if (connection.noNewExchanges || maxIdleConnections == 0) { connection.noNewExchanges = true connections.remove(connection) if (connections.isEmpty()) cleanupQueue.cancelAll() scheduleOpener(connection.route.address) true } else { scheduleCloser() false } } fun evictAll() { val i = connections.iterator()
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 16.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerTest.kt
blueQueue.execute("task", 100.µs) { error("expected to be canceled") } assertThat(taskFaker.executeCallCount).isEqualTo(1) redQueue.cancelAll() assertThat(taskFaker.executeCallCount).isEqualTo(1) blueQueue.cancelAll() assertThat(taskFaker.executeCallCount).isEqualTo(1) } @Test fun noMoreThanOneWorkerThreadWaitingToStartAtATime() {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Apr 29 00:33:04 UTC 2024 - 23K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
try { backend.coordinatorWait(this@TaskRunner, minDelayNanos) } catch (_: InterruptedException) { // Will cause all tasks to exit unless more are scheduled! cancelAll() } finally { coordinatorWaiting = false } } } } } /** Start another thread, unless a new thread is already scheduled to start. */
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Apr 29 00:33:04 UTC 2024 - 10.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt
* will not be made until any currently-executing task has completed. Tasks that return true will * be removed from the execution schedule. */ fun cancelAll() { lock.assertNotHeld() taskRunner.lock.withLock { if (cancelAllAndDecide()) { taskRunner.kickCoordinator(this) } } } fun shutdown() {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 7.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Dispatcher.kt
} return null } /** * Cancel all calls currently enqueued or executing. Includes calls executed both * [synchronously][Call.execute] and [asynchronously][Call.enqueue]. */ fun cancelAll() { this.withLock { for (call in readyAsyncCalls) { call.call.cancel() } for (call in runningAsyncCalls) { call.call.cancel() }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Thu Jun 20 14:10:53 UTC 2024 - 9K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt
val waitTime = (entryTime + 1_000_000_000L - System.nanoTime()) if (!queue.idleLatch().await(waitTime, TimeUnit.NANOSECONDS)) { TaskRunner.INSTANCE.lock.withLock { TaskRunner.INSTANCE.cancelAll() } fail<Unit>("Queue still active after 1000 ms") } } } override fun beforeEach(context: ExtensionContext) { testName = context.displayName beforeEach()
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 10.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/KotlinSourceModernTest.kt
val runningCalls: List<Call> = dispatcher.runningCalls() val queuedCallsCount: Int = dispatcher.queuedCallsCount() val runningCallsCount: Int = dispatcher.runningCallsCount() dispatcher.cancelAll() } @Test fun dispatcherFromMockWebServer() { val dispatcher = object : okhttp3.mockwebserver.Dispatcher() { override fun dispatch(request: RecordedRequest): MockResponse = TODO()
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Apr 01 14:21:25 UTC 2024 - 46.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CallTest.kt
latch.countDown() callback.await(server.url("/a")).assertFailure("Canceled", "Socket closed", "Socket is closed") } @Test fun cancelAll() { val call = client.newCall(Request(server.url("/"))) call.enqueue(callback) client.dispatcher.cancelAll() callback.await(server.url("/")).assertFailure("Canceled", "Socket closed", "Socket is closed") } @Test
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Wed Apr 10 19:46:48 UTC 2024 - 142.5K bytes - Viewed (0) -
okhttp/api/okhttp.api
public final class okhttp3/Dispatcher { public final fun -deprecated_executorService ()Ljava/util/concurrent/ExecutorService; public fun <init> ()V public fun <init> (Ljava/util/concurrent/ExecutorService;)V public final fun cancelAll ()V public final fun executorService ()Ljava/util/concurrent/ExecutorService; public final fun getIdleCallback ()Ljava/lang/Runnable; public final fun getMaxRequests ()I public final fun getMaxRequestsPerHost ()I
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Apr 15 13:41:01 UTC 2024 - 70.2K bytes - Viewed (0)