- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for isReady (0.12 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/connection/ReusePlan.kt
*/ package okhttp3.internal.connection /** Reuse a connection from the pool. */ internal class ReusePlan( val connection: RealConnection, ) : RoutePlanner.Plan { override val isReady = true override fun connectTcp() = error("already connected") override fun connectTlsEtc() = error("already connected") override fun handleSuccess() = connection
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt
cancelInFlightConnects() // Finish connecting. We won't have to if the winner is from the connection pool. if (!connectResult.plan.isReady) { connectResult = connectResult.plan.connectTlsEtc() } if (connectResult.isSuccess) { return connectResult.plan.handleSuccess() } }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 5.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/FailedPlan.kt
* proxy in a list, looking up a subsequent one may succeed. */ internal class FailedPlan(e: Throwable) : RoutePlanner.Plan { val result = RoutePlanner.ConnectResult(plan = this, throwable = e) override val isReady = false override fun connectTcp() = result override fun connectTlsEtc() = result override fun handleSuccess() = error("unexpected call") override fun cancel() = error("unexpected cancel")
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Wed Dec 20 23:27:07 UTC 2023 - 1.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/SequentialExchangeFinder.kt
var firstException: IOException? = null while (true) { if (routePlanner.isCanceled()) throw IOException("Canceled") try { val plan = routePlanner.plan() if (!plan.isReady) { val tcpConnectResult = plan.connectTcp() val connectResult = when { tcpConnectResult.isSuccess -> plan.connectTlsEtc() else -> tcpConnectResult }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 1.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RoutePlanner.kt
* These steps are split so callers can call [connectTcp] on a background thread if attempting * multiple plans concurrently. */ interface Plan { val isReady: Boolean fun connectTcp(): ConnectResult fun connectTlsEtc(): ConnectResult fun handleSuccess(): RealConnection fun cancel() /**
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Wed Dec 20 23:27:07 UTC 2023 - 4.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/FakeRoutePlanner.kt
idleAtNanos = defaultConnectionIdleAtNanos, ) var retry: FakePlan? = null var retryTaken = false var yieldBeforePlanReturns = false override val isReady: Boolean get() = connectState == ConnectState.TLS_CONNECTED var tcpConnectDelayNanos = 0L var tcpConnectThrowable: Throwable? = null var yieldBeforeTcpConnectReturns = false
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Wed Apr 24 04:40:49 UTC 2024 - 6.2K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/IteratorTester.java
* * <p>To use this class the concrete subclass must implement the {@link * IteratorTester#newTargetIterator()} method. This is because it's impossible to test an Iterator * without changing its state, so the tester needs a steady supply of fresh Iterators. * * <p>If your iterator supports modification through {@code remove()}, you may wish to override the * verify() method, which is called after each sequence and is guaranteed to be called
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Feb 21 16:49:06 UTC 2024 - 4.3K bytes - Viewed (0)