- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for removeMax (0.07 sec)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
} for (i in readyQueues.size - 1 downTo 0) { val queue = readyQueues[i] queue.cancelAllAndDecide() if (queue.futureTasks.isEmpty()) { readyQueues.removeAt(i) } } } interface Backend { fun nanoTime(): Long fun coordinatorNotify(taskRunner: TaskRunner) fun coordinatorWait( taskRunner: TaskRunner,
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 30 11:30:11 UTC 2025 - 10.4K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealCall.kt
val connection = this.connection!! connection.assertLockHeld() val calls = connection.calls val index = calls.indexOfFirst { it.get() == this@RealCall } check(index != -1) calls.removeAt(index) this.connection = null if (calls.isEmpty()) { connection.idleAtNs = System.nanoTime() if (connectionPool.connectionBecameIdle(connection)) { return connection.socket()
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 30 11:30:11 UTC 2025 - 17.8K bytes - Viewed (0)