Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for isReady (0.12 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
Back to top