- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 20 for connect (0.15 sec)
-
okhttp-sse/src/main/kotlin/okhttp3/sse/EventSources.kt
request.newBuilder().addHeader("Accept", "text/event-stream").build() } else { request } RealEventSource(actualRequest, listener).apply { connect(callFactory) } } } @JvmStatic fun processResponse( response: Response, listener: EventSourceListener, ) { val eventSource = RealEventSource(response.request, listener)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 04:18:15 GMT 2024 - 1.6K bytes - Viewed (1) -
okhttp/src/test/java/okhttp3/CallTest.kt
val connect1 = server.takeRequest() assertThat(connect1.requestLine).isEqualTo("CONNECT android.com:443 HTTP/1.1") assertThat(connect1.headers["Proxy-Authorization"]).isNull() val connect2 = server.takeRequest() assertThat(connect2.requestLine).isEqualTo("CONNECT android.com:443 HTTP/1.1") assertThat(connect2.headers["Proxy-Authorization"]).isEqualTo("password")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 142.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt
internal fun connectFailed( client: OkHttpClient, failedRoute: Route, failure: IOException, ) { // Tell the proxy selector when we fail to connect on a fresh connection. if (failedRoute.proxy.type() != Proxy.Type.DIRECT) { val address = failedRoute.address address.proxySelector.connectFailed( address.url.toUri(),
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 15.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectPlan.kt
import okio.BufferedSource import okio.buffer import okio.sink import okio.source /** * A single attempt to connect to a remote server, including these steps: * * * [TCP handshake][connectSocket] * * Optional [CONNECT tunnels][connectTunnel]. When using an HTTP proxy to reach an HTTPS server * we must send a `CONNECT` request, and handle authorization challenges from the proxy. * * Optional [TLS handshake][connectTls]. *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 18.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/FakeRoutePlanner.kt
} else -> { events += "plan $id TCP connected" connectState = ConnectState.TCP_CONNECTED ConnectResult(this) } } } override fun connectTlsEtc(): ConnectResult { check(connectState == ConnectState.TCP_CONNECTED) events += "plan $id TLS connecting..." taskFaker.sleep(tlsConnectDelayNanos)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 6.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt
val connect = planConnect() // Now that we have a set of IP addresses, make another attempt at getting a connection from // the pool. We have a better chance of matching thanks to connection coalescing. val pooled2 = planReusePooledConnection(connect, connect.routes) if (pooled2 != null) return pooled2 return connect } /**
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 12K bytes - Viewed (0) -
docs/changelogs/changelog_4x.md
two addresses are encoded differently, such as `192.168.1.1` and `0::0:0:FFFF:C0A8:101`. Note that OkHttp incorrectly rejected valid certificates resulting in a failure to connect; at no point were invalid certificates accepted. * New: `OkHttpClient.Builder.minWebSocketMessageToCompress()` configures a threshold for
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 17 13:25:31 GMT 2024 - 25.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
val connect1 = server.takeRequest() assertThat(connect1.requestLine).isEqualTo("CONNECT android.com:$port HTTP/1.1") assertThat(connect1.headers["Proxy-Authorization"]).isNull() val connect2 = server.takeRequest() assertThat(connect2.requestLine).isEqualTo("CONNECT android.com:$port HTTP/1.1") assertThat(connect2.headers["Proxy-Authorization"]).isEqualTo("password")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 75.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt
* there is for the connect, write, and read actions within a call. * * For WebSockets and duplex calls the timeout only applies to the initial setup. */ @get:JvmName("callTimeoutMillis") val callTimeoutMillis: Int = builder.callTimeout /** Default connect timeout (in milliseconds). The default is 10 seconds. */ @get:JvmName("connectTimeoutMillis")
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) -
okhttp/src/test/java/okhttp3/SocksProxy.kt
} } else -> throw ProtocolException("unsupported address type: $addressType") } val port = fromSource.readShort() and 0xffff when (command) { COMMAND_CONNECT -> { val toSocket = Socket(toAddress, port) val localAddress = toSocket.localAddress.address if (localAddress.size != 4) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 7.7K bytes - Viewed (0)