- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 20 for readTimeouts (0.06 seconds)
-
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/storage/StorageClient.java
final long readTimeout = getInitParameter("readTimeout", (long) 10000, Long.class); minioClient.setTimeout(connectTimeout, writeTimeout, readTimeout); isInit = true; if (logger.isInfoEnabled()) { logger.info("Storage client initialized successfully: endpoint={}, connectTimeout={}ms, writeTimeout={}ms, readTimeout={}ms",
Created: Sat Dec 20 11:21:39 GMT 2025 - Last Modified: Mon Nov 24 03:59:47 GMT 2025 - 20K bytes - Click Count (2) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/OkHttpClient.kt
* including on [Source] of the [Response]. The default value is 10 seconds. * * @see Socket.setSoTimeout * @see Source.timeout */ fun readTimeout( timeout: Long, unit: TimeUnit, ) = apply { readTimeout = checkDuration("timeout", timeout, unit) } /** * Sets the default read timeout for new connections. A value of 0 means no timeout, otherwise
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue Oct 07 21:55:03 GMT 2025 - 51.4K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/DuplexTest.kt
.url(server.url("/")) .post(DelayedRequestBody("hello".toRequestBody(null), 1500, TimeUnit.MILLISECONDS)) .build() client = client .newBuilder() .readTimeout(1000, TimeUnit.MILLISECONDS) .build() val call = client.newCall(request) assertFailsWith<IOException> { call.execute() }.also { expected ->
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue Nov 04 19:13:52 GMT 2025 - 25.8K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HttpOverHttp2Test.kt
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Sat Nov 01 12:18:11 GMT 2025 - 67.4K bytes - Click Count (0) -
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 Dec 26 11:42:13 GMT 2025 - Last Modified: Sat Aug 30 17:01:12 GMT 2025 - 47.8K bytes - Click Count (0) -
.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 ScanCreated: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Thu Dec 11 22:12:03 GMT 2025 - 4K bytes - Click Count (0) -
internal/http/server.go
srv.IdleTimeout = d return srv } // UseReadTimeout configure connection request read timeout. func (srv *Server) UseReadTimeout(d time.Duration) *Server { srv.ReadTimeout = d return srv } // UseReadHeaderTimeout configure read header timeout func (srv *Server) UseReadHeaderTimeout(d time.Duration) *Server { srv.ReadHeaderTimeout = d return srv }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 6.5K bytes - Click Count (0) -
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 Dec 26 11:42:13 GMT 2025 - Last Modified: Sat Nov 01 12:18:11 GMT 2025 - 7.9K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/ConnectionListenerTest.kt
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue Nov 04 18:33:48 GMT 2025 - 9.7K bytes - Click Count (0) -
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 Dec 26 11:42:13 GMT 2025 - Last Modified: Tue Nov 04 19:13:52 GMT 2025 - 35.5K bytes - Click Count (0)