- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for TaskRunner (0.04 sec)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/OkHttpClient.kt
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon May 05 16:01:00 UTC 2025 - 51.7K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/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 Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 75.7K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2ConnectionTest.kt
peer.acceptFrame() // SYN_STREAM. peer.play() val taskRunner = taskFaker.taskRunner val connection = Http2Connection .Builder(true, taskRunner) .socket(peer.openSocket().asBufferedSocket(), "peer") .pushObserver(IGNORE) .build() connection.start(sendConnectionPreface = false) val queues = taskRunner.activeQueues() assertThat(queues).hasSize(1) }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 75.5K bytes - Viewed (0)