Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 26 for plans (0.02 sec)

  1. okhttp/src/jvmTest/kotlin/okhttp3/FakeRoutePlanner.kt

        if (nextPlanIndex >= plans.size && autoGeneratePlans) addPlan()
    
        require(nextPlanIndex < plans.size) {
          "not enough plans! call addPlan() or set autoGeneratePlans=true in the test to set this up"
        }
        val result = plans[nextPlanIndex++]
        events += "take plan ${result.id}"
    
        if (result.yieldBeforePlanReturns) {
          taskFaker.yield()
        }
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 6.1K bytes
    - Viewed (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RoutePlanner.kt

     */
    interface RoutePlanner {
      val address: Address
    
      /** Follow-ups for failed plans and plans that lost a race. */
      val deferredPlans: ArrayDeque<Plan>
    
      fun isCanceled(): Boolean
    
      /** Returns a plan to attempt. */
      @Throws(IOException::class)
      fun plan(): Plan
    
      /**
       * Returns true if there's more route plans to try.
       *
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue May 27 14:58:02 UTC 2025
    - 4.2K bytes
    - Viewed (0)
  3. README.md

        period. The last release to remove non-`@Beta` APIs was Guava 21.0.) Even
        `@Deprecated` APIs will remain (again, unless they are `@Beta`). We have no
        plans to start removing things again, but officially, we're leaving our
        options open in case of surprises (like, say, a serious security problem).
    
    3.  Guava has one dependency that is needed for linkage at runtime:
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue Aug 05 15:30:14 UTC 2025
    - 6.2K bytes
    - Viewed (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt

      private var routeSelector: RouteSelector? = null
      private var nextRouteToTry: Route? = null
    
      override val deferredPlans = ArrayDeque<Plan>()
    
      override fun isCanceled(): Boolean = connectionUser.isCanceled()
    
      @Throws(IOException::class)
      override fun plan(): Plan {
        val reuseCallConnection = planReuseCallConnection()
        if (reuseCallConnection != null) return reuseCallConnection
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 12K bytes
    - Viewed (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/ConnectionPoolTest.kt

        routePlanner.defaultConnectionIdleAtNanos = expireSooner
    
        // Turn it into an http/2 connection that supports 5 concurrent streams
        // which can satisfy a larger policy
        val connection = routePlanner.plans.first().connection
        val http2Connection = connectHttp2(peer, connection, 5)
        setPolicy(pool, address, AddressPolicy(5))
        assertThat(pool.connectionCount()).isEqualTo(1)
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 12.9K bytes
    - Viewed (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ForceConnectRoutePlanner.kt

     */
    class ForceConnectRoutePlanner(
      private val delegate: RealRoutePlanner,
    ) : RoutePlanner by delegate {
      override fun plan(): RoutePlanner.Plan = delegate.planConnect() // not delegate.plan()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 937 bytes
    - Viewed (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ConnectPlan.kt

      private val user: ConnectionUser,
      private val routePlanner: RealRoutePlanner,
      // Specifics to this plan.
      override val route: Route,
      internal val routes: List<Route>?,
      private val attempt: Int,
      private val tunnelRequest: Request?,
      internal val connectionSpecIndex: Int,
      internal val isTlsFallback: Boolean,
    ) : RoutePlanner.Plan,
      ExchangeCodec.Carrier {
      /** True if this connect was canceled; typically because it lost a race. */
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 18.6K bytes
    - Viewed (0)
  8. okhttp/src/commonJvmAndroid/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
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 1.5K bytes
    - Viewed (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealCall.kt

       */
      override fun cancel() {
        if (canceled) return // Already canceled.
    
        canceled = true
        exchange?.cancel()
        for (plan in plansToCancel) {
          plan.cancel()
        }
    
        eventListener.canceled(this)
      }
    
      override fun isCanceled(): Boolean = canceled
    
      override fun execute(): Response {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 30 11:30:11 UTC 2025
    - 17.8K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/base/StandardSystemProperty.java

       *
       * @deprecated This property was <a
       *     href="https://openjdk.java.net/jeps/220#Removed:-The-extension-mechanism">deprecated</a> in
       *     Java 8 and removed in Java 9. We do not plan to remove this API from Guava, but if you are
       *     using it, it is probably not doing what you want.
       */
      @Deprecated
      JAVA_EXT_DIRS("java.ext.dirs"),
    
      /** Operating system name. */
      OS_NAME("os.name"),
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Mar 06 10:03:30 UTC 2025
    - 4.9K bytes
    - Viewed (0)
Back to top