- Sort Score
- Num 10 results
- Language All
Results 1 - 3 of 3 for newConnections (0.11 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
okhttp/src/jvmTest/kotlin/okhttp3/FakeRoutePlanner.kt
inner class FakePlan( val id: Int, ) : RoutePlanner.Plan { var planningThrowable: Throwable? = null var canceled = false var connectState = ConnectState.READY val connection = factory.newConnection( pool = pool, route = factory.newRoute(address), idleAtNanos = defaultConnectionIdleAtNanos, ) var retry: FakePlan? = null var retryTaken = false
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue Oct 07 21:55:03 GMT 2025 - 6.1K bytes - Click Count (0) -
internal/grid/connection.go
publisher *pubsub.PubSub[madmin.TraceInfo, madmin.TraceType] dialer ConnDialer authFn AuthFn blockConnect chan struct{} } // newConnection will create an unconnected connection to a remote. func newConnection(o connectionParams) *Connection { c := &Connection{ state: StateUnconnected, Remote: o.remote, Local: o.local,
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 46.9K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/EventListenerTest.kt
localCertificates = listOf(), ) return mapOf( Boolean::class.java to false, Call::class.java to FailingCall(), Connection::class.java to factory.newConnection(pool, route), Dispatcher::class.java to Dispatcher(), Handshake::class.java to handshake, HttpUrl::class.java to url, IOException::class.java to IOException("boom"),
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Nov 05 18:28:35 GMT 2025 - 70.5K bytes - Click Count (0)