- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for enterNetworkInterceptorExchange (0.14 sec)
-
okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt
val client = OkHttpClient.Builder() .connectionPool(poolApi) .build() val call = client.newCall(Request(addressA.url)) as RealCall call.enterNetworkInterceptorExchange(call.request(), true, factory.newChain(call)) c1.withLock { call.acquireConnectionNoEvents(c1) } // Running at time 50, the pool returns that nothing can be evicted until time 150.
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Jun 22 16:06:35 UTC 2024 - 12.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http/RetryAndFollowUpInterceptor.kt
val call = realChain.call var followUpCount = 0 var priorResponse: Response? = null var newRoutePlanner = true var recoveredFailures = listOf<IOException>() while (true) { call.enterNetworkInterceptorExchange(request, newRoutePlanner, chain) var response: Response var closeActiveExchange = true try { if (call.isCanceled()) { throw IOException("Canceled") }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Apr 15 13:24:48 UTC 2024 - 12.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
* * Note that an exchange will not be needed if the request is satisfied by the cache. * * @param newRoutePlanner true if this is not a retry and new routing can be performed. */ fun enterNetworkInterceptorExchange( request: Request, newRoutePlanner: Boolean, chain: RealInterceptorChain, ) { check(interceptorScopedExchange == null) this.withLock { check(!responseBodyOpen) {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 17.9K bytes - Viewed (0)