- Sort Score
- Result 10 results
- Languages All
Results 11 - 17 of 17 for writeTimeout (0.25 sec)
-
okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt
private val clientListener = WebSocketRecorder("client") 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())
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 35.2K bytes - Viewed (1) -
internal/event/target/kafka.go
config.Producer.Compression = cc config.Producer.CompressionLevel = args.Producer.CompressionLevel } config.Net.ReadTimeout = (5 * time.Second) config.Net.DialTimeout = (5 * time.Second) config.Net.WriteTimeout = (5 * time.Second) config.Metadata.Retry.Max = 1 config.Metadata.Retry.Backoff = (1 * time.Second) config.Metadata.RefreshFrequency = (15 * time.Minute) target.config = config brokers := []string{}
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 20 08:16:35 GMT 2024 - 13K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/KotlinSourceModernTest.kt
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) builder = builder.pingInterval(Duration.ofSeconds(0L)) builder = builder.proxy(Proxy.NO_PROXY)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 01 14:21:25 GMT 2024 - 46.5K bytes - Viewed (4) -
okhttp/src/test/java/okhttp3/InterceptorTest.kt
Interceptor { chain: Interceptor.Chain -> assertThat(chain.writeTimeoutMillis()).isEqualTo(100) chain.proceed(chain.request()) } client = client.newBuilder() .writeTimeout(Duration.ofSeconds(5)) .addInterceptor(interceptor1) .addInterceptor(interceptor2) .build() server.enqueue( MockResponse.Builder() .body("abc")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Jan 14 10:20:09 GMT 2024 - 27.8K bytes - Viewed (0) -
okhttp/api/okhttp.api
public final fun webSocketCloseTimeout-LRDsOJo (J)Lokhttp3/OkHttpClient$Builder; public final fun writeTimeout (JLjava/util/concurrent/TimeUnit;)Lokhttp3/OkHttpClient$Builder; public final fun writeTimeout (Ljava/time/Duration;)Lokhttp3/OkHttpClient$Builder; public final fun writeTimeout-LRDsOJo (J)Lokhttp3/OkHttpClient$Builder; } public final class okhttp3/OkHttpClient$Companion { }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 13:41:01 GMT 2024 - 70.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
val stream = connection.newStream(headerEntries("b", "banana"), true) val sink = stream.getSink() sink.write(Buffer().writeUtf8("abcde"), 5) stream.writeTimeout().timeout(500, TimeUnit.MILLISECONDS) val startNanos = System.nanoTime() sink.write(Buffer().writeUtf8("f"), 1) assertFailsWith<InterruptedIOException> {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 75.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/URLConnectionTest.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 131.7K bytes - Viewed (0)