- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for ForWebsocket (1.53 sec)
-
cmd/grid.go
// useful over persistent connections. Dialer: grid.ConnectWS( grid.ContextDialer(xhttp.DialContextWithLookupHost(lookupHost, xhttp.NewInternodeDialContext(rest.DefaultTimeout, globalTCPOptions.ForWebsocket()))), newCachedAuthToken(), &tls.Config{ RootCAs: globalRootCAs, CipherSuites: crypto.TLSCiphers(), CurvePreferences: crypto.TLSCurveIDs(), }), Local: local,
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri May 16 14:27:42 UTC 2025 - 3.7K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/TestValueFactory.kt
writeTimeoutMillis = 10_000, ) fun newRoutePlanner( client: OkHttpClient, address: Address = newAddress(), ): RealRoutePlanner { val call = RealCall(client, Request(address.url), forWebSocket = false) val chain = newChain(call) return RealRoutePlanner( taskRunner = client.taskRunner, connectionPool = client.connectionPool.delegate, readTimeoutMillis = client.readTimeoutMillis,
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri May 30 21:28:20 UTC 2025 - 7.7K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Dispatcher.kt
synchronized(this) { readyAsyncCalls.add(call) // Mutate the AsyncCall so that it shares the AtomicInteger of an existing running call to // the same host. if (!call.call.forWebSocket) { val existingCall = findExistingCallWithHost(call.host) if (existingCall != null) call.reuseCallsPerHostFrom(existingCall) } } promoteAndExecute() }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed May 28 23:28:25 UTC 2025 - 8.7K bytes - Viewed (0)