Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 4 of 4 for TaskFaker (0.05 seconds)

  1. okhttp-testing-support/src/main/kotlin/okhttp3/TestValueFactory.kt

     * configure the factory when sample values impact the correctness of the test.
     */
    class TestValueFactory : Closeable {
      var taskFaker: TaskFaker = TaskFaker()
      var taskRunner: TaskRunner = taskFaker.taskRunner
      var dns: Dns = Dns.SYSTEM
      var proxy: Proxy = Proxy.NO_PROXY
      var proxySelector: ProxySelector = RecordingProxySelector()
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Jan 11 12:06:21 GMT 2026
    - 6.6K bytes
    - Click Count (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/FakeRoutePlanner.kt

    import java.util.concurrent.LinkedBlockingDeque
    import okhttp3.internal.concurrent.TaskFaker
    import okhttp3.internal.connection.RealConnection
    import okhttp3.internal.connection.RoutePlanner
    import okhttp3.internal.connection.RoutePlanner.ConnectResult
    
    class FakeRoutePlanner(
      val factory: TestValueFactory = TestValueFactory(),
      val taskFaker: TaskFaker = factory.taskFaker,
    ) : RoutePlanner,
      Closeable {
      val pool = factory.newConnectionPool()
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 6.1K bytes
    - Click Count (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/internal/concurrent/TaskRunnerTest.kt

        }
    
        redQueue.execute("task two", 100.µs) {
          log += "two:run@${taskFaker.nanoTime} parallel=${taskFaker.isParallel}"
        }
    
        redQueue.execute("task three", 100.µs) {
          log += "three:run@${taskFaker.nanoTime} parallel=${taskFaker.isParallel}"
        }
    
        taskFaker.advanceUntil(0.µs)
        assertThat(log).isEmpty()
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Feb 03 22:17:59 GMT 2026
    - 23K bytes
    - Click Count (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/internal/cache/DiskLruCacheTest.kt

            else -> cacheDirFile.path.toPath()
          }
      private val appVersion = 100
      private lateinit var journalFile: Path
      private lateinit var journalBkpFile: Path
      private val taskFaker = TaskFaker()
      private val taskRunner = taskFaker.taskRunner
      private lateinit var cache: DiskLruCache
      private val toClose = ArrayDeque<DiskLruCache>()
    
      private fun createNewCache() {
        createNewCacheWithSize(Int.MAX_VALUE)
      }
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Feb 03 22:17:59 GMT 2026
    - 59.4K bytes
    - Click Count (0)
Back to Top