- Sort Score
- Num 10 results
- Language All
Results 11 - 20 of 32 for readTimeout (0.06 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
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) -
.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 Apr 01 11:36:16 GMT 2026 - Last Modified: Thu Dec 11 22:12:03 GMT 2025 - 4K bytes - Click Count (0) -
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) -
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) -
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) -
okhttp/src/jvmTest/kotlin/okhttp3/ConnectionListenerTest.kt
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) -
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) -
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) -
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) -
impl/maven-core/src/main/java/org/apache/maven/internal/aether/DefaultRepositorySystemSessionFactory.java
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)