- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 138 for plans (0.04 sec)
-
okhttp/src/test/java/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 Nov 01 11:42:11 UTC 2024 - Last Modified: Wed Apr 24 04:40:49 UTC 2024 - 6.2K bytes - Viewed (0) -
okhttp/src/main/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 Nov 01 11:42:11 UTC 2024 - Last Modified: Wed Dec 20 23:27:07 UTC 2023 - 4.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt
if (plan is FailedPlan) return plan.result // Connect TCP asynchronously. tcpConnectsInFlight += plan val taskName = "$okHttpName connect ${routePlanner.address.url.redact()}" taskRunner.newQueue().schedule( object : Task(taskName) { override fun runOnce(): Long { val connectResult = try { plan.connectTcp()
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/test/java/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt
plan0.tcpConnectDelayNanos = 280.ms val plan1 = routePlanner.addPlan() plan1.tcpConnectDelayNanos = 10.ms // Connect at time = 260 ms. plan1.tlsConnectDelayNanos = 10.ms // Connect at time = 270 ms. plan1.tlsConnectThrowable = IOException("boom!") val plan2 = plan1.createConnectTlsNextPlan() plan2.tcpConnectDelayNanos = 270.ms // Connect at time = 540 ms. val plan3 = plan0.createRetry()
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Wed Apr 24 04:40:49 UTC 2024 - 20.9K bytes - Viewed (0) -
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 Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Sep 24 18:34:38 UTC 2024 - 5.9K bytes - Viewed (0) -
okhttp/src/main/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 Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 12K bytes - Viewed (0) -
okhttp/src/test/java/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, ConnectionPool.AddressPolicy(5)) assertThat(pool.connectionCount()).isEqualTo(1)
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Jun 22 16:06:35 UTC 2024 - 12.8K bytes - Viewed (0) -
android/guava/src/com/google/common/base/Optional.java
* OptionalLong} and {@code OptionalDouble}, the use of which is recommended; Guava does not * have these. * </ul> * * <p><b>There are no plans to deprecate this class in the foreseeable future.</b> However, we do * gently recommend that you prefer the new, standard Java class whenever possible. * * <p>See the Guava User Guide article on <a
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 31 14:20:11 UTC 2024 - 15.4K bytes - Viewed (0) -
docs/pt/docs/tutorial/background-tasks.md
```Python hl_lines="13 15 22 25" {!../../docs_src/background_tasks/tutorial002.py!} ``` Neste exemplo, as mensagens serão gravadas no arquivo `log.txt` _após_ o envio da resposta. Se houver uma consulta na solicitação, ela será gravada no log em uma tarefa em segundo plano.
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 06 20:36:54 UTC 2024 - 5.3K bytes - Viewed (0) -
istioctl/pkg/proxystatus/proxystatus.go
# (Certificates must be obtained before this step. The --cert-dir flag lets istioctl bypass the Kubernetes API server.) istioctl ps --xds-address istio.example.com:15012 --cert-dir ~/.istio-certs # Retrieve proxy status information via XDS from specific control plane in multi-control plane in-cluster configuration
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Sat Apr 13 05:23:38 UTC 2024 - 6.2K bytes - Viewed (0)