- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for runTasks (0.18 sec)
-
okhttp/src/test/java/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt
plan0.connectState = TLS_CONNECTED taskRunner.newQueue().execute("connect") { val result0 = finder.find() assertThat(result0).isEqualTo(plan0.connection) } taskFaker.runTasks() assertEvents( "take plan 0", ) taskFaker.assertNoMoreTasks() } @Test fun takeConnectingConnection() { val plan0 = routePlanner.addPlan()
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 20.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt
taskFaker.runTasks() client.listener.assertFailure(IOException::class.java, "source is closed") assertThat(client.webSocket!!.send("Hello!")).isFalse() } @Test fun socketClosedDuringMessageKillsWebSocket() { client2Server.source.close() assertThat(client.webSocket!!.send("Hello!")).isTrue() taskFaker.runTasks()
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Thu Apr 11 01:59:58 GMT 2024 - 18.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt
address: Address, policy: ConnectionPool.AddressPolicy, ) { pool.setPolicy(address, policy) taskFaker.runTasks() } private fun evictAllConnections(pool: RealConnectionPool) { pool.evictAll() assertThat(pool.connectionCount()).isEqualTo(0) taskFaker.runTasks() } private fun forceConnectionsToExpire( pool: RealConnectionPool, expireTime: Long, ) {
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 12.7K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
* deterministic. * * This class ensures that at most one thread is running at a time. This is initially the JUnit test * thread, which yields its execution privilege while calling [runTasks], [runNextTask], or * [advanceUntil]. These functions don't return until the task threads are all idle. * * Task threads release their execution privilege in these ways: *
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 12.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
awaitTaskToRun() } ?: return logger.logElapsed(task, task.queue!!) { var completedNormally = false try { runTask(task) completedNormally = true } finally { // If the task is crashing start another thread to service the queues. if (!completedNormally) { lock.withLock {
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.6K bytes - Viewed (0) -
okhttp-android/src/main/baseline-prof.txt
HSPLokhttp3/internal/concurrent/TaskRunner;-><clinit>()V HSPLokhttp3/internal/concurrent/TaskRunner;-><init>(Lokhttp3/internal/concurrent/TaskRunner$Backend;Ljava/util/logging/Logger;I)V HSPLokhttp3/internal/concurrent/TaskRunner;->access$runTask(Lokhttp3/internal/concurrent/TaskRunner;Lokhttp3/internal/concurrent/Task;)V HSPLokhttp3/internal/concurrent/TaskRunner;->afterRun(Lokhttp3/internal/concurrent/Task;J)V
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Mar 21 11:22:00 GMT 2022 - 127.9K bytes - Viewed (0) -
ChangeLog.md
- [`KT-42520`](https://youtrack.jetbrains.com/issue/KT-42520) Add a way to setup generating separate js files for each module inside gradle - [`KT-32086`](https://youtrack.jetbrains.com/issue/KT-32086) Gradle, JS: runTask.enabled = false has no effect on npm dependencies - [`KT-48358`](https://youtrack.jetbrains.com/issue/KT-48358) KJS: Circular dependency when multiple second-level Gradle modules have the same name
Plain Text - Registered: Fri Apr 26 08:18:10 GMT 2024 - Last Modified: Thu Dec 21 17:48:12 GMT 2023 - 268.7K bytes - Viewed (1)