Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 11 - 20 of 32 for readTimeout (0.06 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. docs/recipes.md

    === ":material-language-kotlin: Kotlin"
        ```kotlin
          private val client: OkHttpClient = OkHttpClient.Builder()
              .connectTimeout(5, TimeUnit.SECONDS)
              .writeTimeout(5, TimeUnit.SECONDS)
              .readTimeout(5, TimeUnit.SECONDS)
              .callTimeout(10, TimeUnit.SECONDS)
              .build()
    
          fun run() {
            val request = Request.Builder()
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Mar 15 09:01:42 GMT 2026
    - 47.8K bytes
    - Click Count (0)
  2. .github/workflows/codeql-analysis.yml

          env:
            # Set the DEVELOCITY_ACCESS_KEY so that a Build Scan is generated
            DEVELOCITY_ACCESS_KEY: ${{ secrets.DEVELOCITY_ACCESS_KEY }}
            # Potential stop-gap solution for ReadTimeout issues with the Gradle Build Cache
            # https://gradle.slack.com/archives/CHDLT99C6/p1636477584059200
            GRADLE_OPTS: -Dhttp.keepAlive=false
    
        - name: Compile with Gradle without publishing a Build Scan
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Thu Dec 11 22:12:03 GMT 2025
    - 4K bytes
    - Click Count (0)
  3. mockwebserver/src/test/java/mockwebserver3/MockWebServerTest.kt

        )
        server.enqueue(
          MockResponse
            .Builder()
            .body("DEF")
            .build(),
        )
        val urlConnection = server.url("/").toUrl().openConnection()
        urlConnection!!.readTimeout = 1000
        val inputStream = urlConnection.getInputStream()
        assertThat(inputStream!!.read()).isEqualTo('A'.code)
        assertThat(inputStream.read()).isEqualTo('B'.code)
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Aug 03 22:38:00 GMT 2025
    - 28K bytes
    - Click Count (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/SocketChannelTest.kt

        val client =
          clientTestRule
            .newClientBuilder()
            .dns { listOf(InetAddress.getByName("localhost")) }
            .callTimeout(4, SECONDS)
            .writeTimeout(2, SECONDS)
            .readTimeout(2, SECONDS)
            .apply {
              if (socketMode is TlsInstance) {
                if (socketMode.socketMode == Channel) {
                  socketFactory(ChannelSocketFactory())
                }
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sat Nov 01 12:18:11 GMT 2025
    - 7.9K bytes
    - Click Count (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2ExchangeCodec.kt

        // headers, but there was still no stream to close.
        if (canceled) {
          stream!!.closeLater(ErrorCode.CANCEL)
          throw IOException("Canceled")
        }
        stream!!.readTimeout().timeout(chain.readTimeoutMillis.toLong(), TimeUnit.MILLISECONDS)
        stream!!.writeTimeout().timeout(chain.writeTimeoutMillis.toLong(), TimeUnit.MILLISECONDS)
      }
    
      override fun flushRequest() {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jul 29 21:11:09 GMT 2025
    - 7K bytes
    - Click Count (0)
  6. okhttp/src/jvmTest/kotlin/okhttp3/ConnectionListenerTest.kt

        server.enqueue(
          MockResponse
            .Builder()
            .headersDelay(2, TimeUnit.SECONDS)
            .build(),
        )
        client =
          client
            .newBuilder()
            .readTimeout(Duration.ofMillis(250))
            .build()
        val call =
          client.newCall(
            Request
              .Builder()
              .url(server.url("/"))
              .build(),
          )
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Nov 04 18:33:48 GMT 2025
    - 9.7K bytes
    - Click Count (0)
  7. okhttp/src/jvmTest/kotlin/okhttp3/CallKotlinTest.kt

        proxySelector.proxies.add(Proxy.NO_PROXY)
        server.close()
    
        client =
          client
            .newBuilder()
            .proxySelector(proxySelector)
            .readTimeout(Duration.ofMillis(100))
            .connectTimeout(Duration.ofMillis(100))
            .build()
    
        val request = Request(server.url("/"))
        assertFailsWith<IOException> {
          client.newCall(request).execute()
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Fri Jun 20 11:46:46 GMT 2025
    - 8.4K bytes
    - Click Count (0)
  8. okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketHttpTest.kt

      private val serverListener = WebSocketRecorder("server")
      private val random = Random(0)
      private var client =
        clientTestRule
          .newClientBuilder()
          .writeTimeout(Duration.ofMillis(500))
          .readTimeout(Duration.ofMillis(500))
          .addInterceptor(
            Interceptor { chain: Interceptor.Chain ->
              val response = chain.proceed(chain.request())
              // Ensure application interceptors never see a null body.
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 35.5K bytes
    - Click Count (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/RealInterceptorChain.kt

        timeout: Int,
        unit: TimeUnit,
      ): Interceptor.Chain {
        check(exchange == null) { "Timeouts can't be adjusted in a network interceptor" }
    
        return copy(readTimeoutMillis = checkDuration("readTimeout", timeout.toLong(), unit))
      }
    
      override fun writeTimeoutMillis(): Int = writeTimeoutMillis
    
      override fun withWriteTimeout(
        timeout: Int,
        unit: TimeUnit,
      ): Interceptor.Chain {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Mar 10 21:47:20 GMT 2026
    - 12.8K bytes
    - Click Count (0)
  10. impl/maven-core/src/main/java/org/apache/maven/internal/aether/DefaultRepositorySystemSessionFactory.java

                            if (httpConfigurationAll != null) {
                                requestTimeoutXml = httpConfigurationAll.getChild("readTimeout", false);
                                if (requestTimeoutXml != null) {
                                    requestTimeout = Integer.parseInt(requestTimeoutXml.getValue());
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Thu Mar 19 13:42:58 GMT 2026
    - 25.8K bytes
    - Click Count (0)
Back to Top