Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 32 for readTimeout (0.2 sec)

  1. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/storage/StorageClient.java

     *   <li>secretKey - The secret key for authentication</li>
     *   <li>connectTimeout - Connection timeout in milliseconds (default: 10000)</li>
     *   <li>writeTimeout - Write timeout in milliseconds (default: 10000)</li>
     *   <li>readTimeout - Read timeout in milliseconds (default: 10000)</li>
     * </ul>
     *
     * <p>The client supports URLs in the format: {@code storage://bucket-name/object-path}
     *
     * <p>Features:
     * <ul>
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 17.9K bytes
    - Viewed (2)
  2. 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()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 8.4K bytes
    - Viewed (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/KotlinSourceModernTest.kt

        builder = builder.connectTimeout(0L, TimeUnit.SECONDS)
        builder = builder.connectTimeout(Duration.ofSeconds(0L))
        builder = builder.readTimeout(0L, TimeUnit.SECONDS)
        builder = builder.readTimeout(Duration.ofSeconds(0L))
        builder = builder.writeTimeout(0L, TimeUnit.SECONDS)
        builder = builder.writeTimeout(Duration.ofSeconds(0L))
        builder = builder.pingInterval(0L, TimeUnit.SECONDS)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Jun 21 20:36:35 UTC 2025
    - 46.5K bytes
    - Viewed (0)
  4. src/main/java/jcifs/http/NtlmHttpURLConnection.java

                }
                return message;
            }
        }
    
        private void reconnect() throws IOException {
            final int readTimeout = getReadTimeout();
            final int connectTimeout = getConnectTimeout();
    
            HostnameVerifier hv = null;
            SSLSocketFactory ssf = null;
            if (this.connection instanceof HttpsURLConnection) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 25.6K bytes
    - Viewed (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/EventListenerTest.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(),
          )
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 60.4K bytes
    - Viewed (0)
  6. okhttp/api/jvm/okhttp.api

    	public final fun proxySelector (Ljava/net/ProxySelector;)Lokhttp3/OkHttpClient$Builder;
    	public final fun readTimeout (JLjava/util/concurrent/TimeUnit;)Lokhttp3/OkHttpClient$Builder;
    	public final fun readTimeout (Ljava/time/Duration;)Lokhttp3/OkHttpClient$Builder;
    	public final fun readTimeout-LRDsOJo (J)Lokhttp3/OkHttpClient$Builder;
    	public final fun retryOnConnectionFailure (Z)Lokhttp3/OkHttpClient$Builder;
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 16 09:39:51 UTC 2025
    - 69.4K bytes
    - Viewed (0)
  7. okhttp/src/jvmTest/kotlin/okhttp3/CallTest.kt

        // First request: time out after 1s.
        client =
          client
            .newBuilder()
            .readTimeout(Duration.ofSeconds(1))
            .build()
        executeSynchronously("/a").assertBody("abc")
    
        // Second request: time out after 250ms.
        client =
          client
            .newBuilder()
            .readTimeout(Duration.ofMillis(250))
            .build()
        val request = Request.Builder().url(server.url("/b")).build()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 146.6K bytes
    - Viewed (0)
  8. okhttp/src/jvmTest/kotlin/okhttp3/InterceptorTest.kt

            assertThat(chain.readTimeoutMillis()).isEqualTo(100)
            chain.proceed(chain.request())
          }
        client =
          client
            .newBuilder()
            .readTimeout(Duration.ofSeconds(5))
            .addInterceptor(interceptor1)
            .addInterceptor(interceptor2)
            .build()
        server.enqueue(
          MockResponse
            .Builder()
            .body("abc")
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 28.2K bytes
    - Viewed (0)
  9. okhttp/api/android/okhttp.api

    	public final fun proxySelector (Ljava/net/ProxySelector;)Lokhttp3/OkHttpClient$Builder;
    	public final fun readTimeout (JLjava/util/concurrent/TimeUnit;)Lokhttp3/OkHttpClient$Builder;
    	public final fun readTimeout (Ljava/time/Duration;)Lokhttp3/OkHttpClient$Builder;
    	public final fun readTimeout-LRDsOJo (J)Lokhttp3/OkHttpClient$Builder;
    	public final fun retryOnConnectionFailure (Z)Lokhttp3/OkHttpClient$Builder;
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 16 09:39:51 UTC 2025
    - 69.4K bytes
    - Viewed (0)
  10. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2ConnectionTest.kt

        peer.acceptFrame() // RST_STREAM
        peer.play()
    
        // Play it back.
        val connection = connect(peer)
        val stream = connection.newStream(headerEntries("b", "banana"), false)
        stream.readTimeout().timeout(500, TimeUnit.MILLISECONDS)
        val startNanos = System.nanoTime()
        assertFailsWith<InterruptedIOException> {
          stream.takeHeaders()
        }
        val elapsedNanos = System.nanoTime() - startNanos
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 75.5K bytes
    - Viewed (0)
Back to top