Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for QueueDispatcher (0.05 sec)

  1. okhttp/src/jvmTest/kotlin/okhttp3/KotlinSourceModernTest.kt

      }
    
      @Test
      fun queueDispatcher() {
        val queueDispatcher = QueueDispatcher()
        var mockResponse: MockResponse =
          queueDispatcher.dispatch(
            RecordedRequest("", headersOf(), listOf(), 0L, Buffer(), 0, Socket()),
          )
        mockResponse = queueDispatcher.peek()
        queueDispatcher.enqueueResponse(MockResponse())
        queueDispatcher.shutdown()
        queueDispatcher.setFailFast(false)
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Nov 05 18:28:35 UTC 2025
    - 47K bytes
    - Viewed (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HttpOverHttp2Test.kt

        val queueDispatcher = QueueDispatcher()
        queueDispatcher.enqueue(
          MockResponse
            .Builder()
            .inTunnel()
            .build(),
        )
        queueDispatcher.enqueue(
          MockResponse
            .Builder()
            .inTunnel()
            .build(),
        )
        queueDispatcher.enqueue(MockResponse(body = "call2 response"))
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sat Nov 01 12:18:11 UTC 2025
    - 67.4K bytes
    - Viewed (0)
  3. CHANGELOG.md

        possible to implement decorators for cache encryption or compression.
     *  New: `Cookie.newBuilder()` to build upon an existing cookie.
     *  New: Use TLSv1.3 when running on JDK 8u261 or newer.
     *  New: `QueueDispatcher.clear()` may be used to reset a MockWebServer instance.
     *  New: `FileDescriptor.toRequestBody()` may be particularly useful for users of Android's Storage
        Access Framework.
     *  Upgrade: [Kotlin 1.5.31][kotlin_1_5_31].
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Dec 05 16:02:59 UTC 2025
    - 36.2K bytes
    - Viewed (2)
  4. okhttp/src/jvmTest/kotlin/okhttp3/CallTest.kt

        // Set to 2 because the seeding request will count down before the retried request does.
        val requestFinished = CountDownLatch(2)
        val dispatcher: QueueDispatcher =
          object : QueueDispatcher() {
            override fun dispatch(request: RecordedRequest): MockResponse {
              if (peek().onResponseStart is CloseSocket) {
                requestFinished.await()
              }
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Nov 04 19:13:52 UTC 2025
    - 147.4K bytes
    - Viewed (0)
Back to top