Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 6 of 6 for bodyDelay (0.05 seconds)

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

            .connectionPool(ConnectionPool(0, 5, TimeUnit.SECONDS))
            .build()
        server.enqueue(
          MockResponse
            .Builder()
            .code(301)
            .addHeader("Location: /b")
            .bodyDelay(1, TimeUnit.SECONDS)
            .body("a")
            .build(),
        )
        server.enqueue(MockResponse(body = "b"))
        val request = Request(server.url("/"))
        val response = client.newCall(request).execute()
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 12.3K bytes
    - Click Count (1)
  2. okhttp/src/jvmTest/kotlin/okhttp3/EventListenerTest.kt

      @Test
      fun successfulChunkedHttpsCallEventSequence() {
        enableTlsWithTunnel()
        server.protocols = Arrays.asList(Protocol.HTTP_1_1)
        server.enqueue(
          MockResponse
            .Builder()
            .bodyDelay(100, TimeUnit.MILLISECONDS)
            .chunkedBody("Hello!", 2)
            .build(),
        )
        assertSuccessfulEventOrder(anyResponse)
        assertBytesReadWritten(
          eventRecorder,
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Feb 03 22:17:59 GMT 2026
    - 70.7K bytes
    - Click Count (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HttpOverHttp2Test.kt

        dispatcher.enqueue(
          MockResponse
            .Builder()
            .bodyDelay(10, TimeUnit.SECONDS)
            .body("abc")
            .build(),
        )
        dispatcher.enqueue(
          MockResponse
            .Builder()
            .bodyDelay(10, TimeUnit.SECONDS)
            .body("def")
            .build(),
        )
        dispatcher.enqueue(
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 67.5K bytes
    - Click Count (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/TrailersTest.kt

        enableProtocol(protocol)
    
        server.enqueue(
          MockResponse
            .Builder()
            .trailers(headersOf("t1", "v2"))
            .bodyDelay(1, TimeUnit.SECONDS)
            .body(protocol, "Hello")
            .build(),
        )
    
        val call = client.newCall(Request(server.url("/")))
        call.execute().use { response ->
          response.close()
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 18.8K bytes
    - Click Count (0)
  5. mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/DeprecationBridge.kt

        SocketPolicy.RESET_STREAM_AT_START -> {
          result.onRequestStart(CloseStream(http2ErrorCode))
        }
      }
    
      result.throttleBody(throttleBytesPerPeriod, getThrottlePeriod(MILLISECONDS), MILLISECONDS)
      result.bodyDelay(getBodyDelay(MILLISECONDS), MILLISECONDS)
      result.headersDelay(getHeadersDelay(MILLISECONDS), MILLISECONDS)
      return result.build()
    }
    
    private fun PushPromise.wrap(): mockwebserver3.PushPromise =
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 4.3K bytes
    - Click Count (1)
  6. okhttp/src/jvmTest/kotlin/okhttp3/KotlinSourceModernTest.kt

        throttleBytesPerPeriod = mockResponse.throttleBytesPerPeriod
        var throttlePeriod: Long = mockResponse.getThrottlePeriod(TimeUnit.SECONDS)
        mockResponse = mockResponse.setBodyDelay(0L, TimeUnit.SECONDS)
        val bodyDelay: Long = mockResponse.getBodyDelay(TimeUnit.SECONDS)
        mockResponse = mockResponse.setHeadersDelay(0L, TimeUnit.SECONDS)
        val headersDelay: Long = mockResponse.getHeadersDelay(TimeUnit.SECONDS)
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Mar 10 21:47:20 GMT 2026
    - 49.7K bytes
    - Click Count (0)
Back to Top