- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for TaskRunner (0.1 sec)
-
okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 06 04:21:33 UTC 2024 - 52K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
peer.acceptFrame() // SYN_STREAM. peer.play() val taskRunner = taskFaker.taskRunner val socket = peer.openSocket() val connection = Http2Connection.Builder(true, taskRunner) .socket(socket) .pushObserver(IGNORE) .build() connection.start(sendConnectionPreface = false) val queues = taskRunner.activeQueues() assertThat(queues).hasSize(1) }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 75.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/cache/DiskLruCacheTest.kt
private val taskRunner = taskFaker.taskRunner private lateinit var cache: DiskLruCache private val toClose = ArrayDeque<DiskLruCache>() private fun createNewCache() { createNewCacheWithSize(Int.MAX_VALUE) } private fun createNewCacheWithSize(maxSize: Int) { cache = DiskLruCache(filesystem, cacheDir, appVersion, 2, maxSize.toLong(), taskRunner).also { toClose.add(it) }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Apr 15 14:55:09 UTC 2024 - 75.8K bytes - Viewed (0)