- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 44 for ArrayDeque (0.54 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/connection/RoutePlanner.kt
* thread executing the call. */ 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. *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 4.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/FakeRoutePlanner.kt
var autoGeneratePlans = false var defaultConnectionIdleAtNanos = Long.MAX_VALUE private var nextPlanId = 0 private var nextPlanIndex = 0 val plans = mutableListOf<FakePlan>() override val deferredPlans = ArrayDeque<RoutePlanner.Plan>() override val address = factory.newAddress("example.com") fun addPlan(): FakePlan { return FakePlan(nextPlanId++).also { plans += it } }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 6.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
*/ package okhttp3.internal.http2 import java.io.EOFException import java.io.IOException import java.io.InterruptedIOException import java.net.SocketTimeoutException import java.util.ArrayDeque import java.util.concurrent.locks.Condition import java.util.concurrent.locks.ReentrantLock import okhttp3.Headers import okhttp3.internal.EMPTY_HEADERS import okhttp3.internal.assertNotHeld
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 23.2K bytes - Viewed (1) -
android/guava/src/com/google/common/collect/MinMaxPriorityQueue.java
import com.google.errorprone.annotations.CanIgnoreReturnValue; import com.google.j2objc.annotations.Weak; import com.google.j2objc.annotations.WeakOuter; import java.util.AbstractQueue; import java.util.ArrayDeque; import java.util.ArrayList; import java.util.Collection; import java.util.Collections; import java.util.Comparator; import java.util.ConcurrentModificationException; import java.util.Iterator;
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Feb 22 21:19:52 GMT 2024 - 34K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Iterators.java
import com.google.common.base.Preconditions; import com.google.common.base.Predicate; import com.google.common.primitives.Ints; import com.google.errorprone.annotations.CanIgnoreReturnValue; import java.util.ArrayDeque; import java.util.Arrays; import java.util.Collection; import java.util.Collections; import java.util.Comparator; import java.util.Deque; import java.util.Enumeration; import java.util.Iterator;
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Apr 30 18:43:01 GMT 2024 - 51.1K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/ReactorReader.java
default: break; } } private Deque<String> getLifecycles(MavenProject project) { return lifecycles.computeIfAbsent(project.getId(), k -> new ArrayDeque<>()); } /** * Copy packaged and attached artifacts from this project to the * project local repository. * This allows a subsequent build to resume while still being able
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Thu May 02 16:33:18 GMT 2024 - 21.3K bytes - Viewed (0) -
maven-artifact/src/main/java/org/apache/maven/artifact/versioning/ComparableVersion.java
* specific language governing permissions and limitations * under the License. */ package org.apache.maven.artifact.versioning; import java.math.BigInteger; import java.util.ArrayDeque; import java.util.ArrayList; import java.util.Arrays; import java.util.Deque; import java.util.Iterator; import java.util.List; import java.util.Locale; import java.util.Objects; import java.util.Properties;
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Wed Sep 06 08:39:32 GMT 2023 - 26K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt
) : RoutePlanner { private var routeSelection: RouteSelector.Selection? = null 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()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 12K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
/** Guarded by [taskRunner]. */ var nanoTime = 0L private set /** Backlog of tasks to run. Only one task runs at a time. Guarded by [TaskRunner.lock]. */ private val serialTaskQueue = ArrayDeque<SerialTask>() /** The task that's currently executing. Guarded by [TaskRunner.lock]. */ private var currentTask: SerialTask = TestThreadSerialTask
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 12.6K bytes - Viewed (0) -
analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/components/KtFirDataFlowInfoProvider.kt
private val statements = statements.toHashSet() private val mapping = HashMap<FirElement, Optional<FirElement>>() private var unmappedCount = statements.size private val stack = ArrayDeque<FirElement>() operator fun get(fir: FirElement): FirElement? { return mapping[fir]?.getOrNull() } override fun visitElement(element: FirElement) {
Plain Text - Registered: Fri Apr 26 08:18:10 GMT 2024 - Last Modified: Tue Apr 16 06:40:43 GMT 2024 - 22.9K bytes - Viewed (0)