Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for TaskRunner (0.1 sec)

  1. okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt

        fun cache(cache: Cache?) =
          apply {
            this.cache = cache
          }
    
        internal fun taskRunner(taskRunner: TaskRunner) =
          apply {
            this.taskRunner = taskRunner
          }
    
        /**
         * Sets the DNS service used to lookup IP addresses for hostnames.
         *
         * If unset, the [system-wide default][Dns.SYSTEM] DNS will be used.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 06 04:21:33 UTC 2024
    - 52K bytes
    - Viewed (0)
  2. 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)
  3. 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)
Back to top