- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for writeTimeout (0.23 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
require(trailers.size != 0) { "trailers.size() == 0" } this.sink.trailers = trailers } } fun readTimeout(): Timeout = readTimeout fun writeTimeout(): Timeout = writeTimeout /** Returns a source that reads data from the peer. */ fun getSource(): Source = source /** * Returns a sink that can be used to write data to the peer. *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 23.2K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt
* The write timeout is applied for individual write IO operations. The default value is 10 * seconds. * * @see Sink.timeout */ fun writeTimeout( timeout: Long, unit: TimeUnit, ) = apply { writeTimeout = checkDuration("timeout", timeout, unit) } /** * Sets the default write timeout for new connections. A value of 0 means no timeout, otherwise
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 04:21:33 GMT 2024 - 52K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/kt/ConfigureTimeouts.kt
import okhttp3.OkHttpClient import okhttp3.Request class ConfigureTimeouts { 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()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/OkHttpClientTest.kt
} catch (ignored: IllegalArgumentException) { } try { builder.connectTimeout(Duration.ofNanos(1)) } catch (ignored: IllegalArgumentException) { } try { builder.writeTimeout(Duration.ofNanos(1)) } catch (ignored: IllegalArgumentException) { } try { builder.readTimeout(Duration.ofNanos(1)) } catch (ignored: IllegalArgumentException) { } try {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 13.2K bytes - Viewed (0) -
okhttp/src/main/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(writeTimeoutMillis = checkDuration("writeTimeout", timeout.toLong(), unit)) } override fun call(): Call = call override fun request(): Request = request @Throws(IOException::class) override fun proceed(request: Request): Response {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.2K bytes - Viewed (0) -
internal/http/listener.go
// When the net.Conn is idle for more than ReadTimeout duration, we close the connection on the client proactively. ClientReadTimeout time.Duration // When the net.Conn is idle for more than WriteTimeout duration, we close the connection on the client proactively. ClientWriteTimeout time.Duration SendBufSize int // SO_SNDBUF size for the socket connection, NOTE: this sets server and client connection
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 5.6K bytes - Viewed (0) -
internal/http/listener_test.go
return nonLoopBackIP } func TestNewHTTPListener(t *testing.T) { testCases := []struct { serverAddrs []string tcpKeepAliveTimeout time.Duration readTimeout time.Duration writeTimeout time.Duration expectedListenErrs []bool }{ {[]string{"93.184.216.34:65432"}, time.Duration(0), time.Duration(0), time.Duration(0), []bool{true}}, // 1
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Jun 12 16:09:28 GMT 2023 - 11.8K bytes - Viewed (0) -
okhttp/src/test/java/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())
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2ExchangeCodec.kt
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() { http2Connection.flush() } override fun finishRequest() { stream!!.getSink().close() }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.9K bytes - Viewed (0) -
internal/logger/target/kafka/kafka.go
sconfig.Producer.RequiredAcks = 1 sconfig.Producer.Timeout = (10 * time.Second) sconfig.Net.ReadTimeout = (10 * time.Second) sconfig.Net.DialTimeout = (10 * time.Second) sconfig.Net.WriteTimeout = (10 * time.Second) sconfig.Metadata.Retry.Max = 1 sconfig.Metadata.Retry.Backoff = (10 * time.Second) sconfig.Metadata.RefreshFrequency = (15 * time.Minute) h.config = sconfig var brokers []string
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 10.1K bytes - Viewed (1)