- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for ArrayDeque (0.29 sec)
-
okhttp/src/main/kotlin/okhttp3/Dispatcher.kt
private val readyAsyncCalls = ArrayDeque<AsyncCall>() /** Running asynchronous calls. Includes canceled calls that haven't finished yet. */ private val runningAsyncCalls = ArrayDeque<AsyncCall>() /** Running synchronous calls. Includes canceled calls that haven't finished yet. */ private val runningSyncCalls = ArrayDeque<RealCall>() constructor(executorService: ExecutorService) : this() {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 9K bytes - Viewed (0) -
guava-testlib/src/com/google/common/testing/ArbitraryInstances.java
setImplementation(Deque.class, ArrayDeque.class); setImplementation(OutputStream.class, ByteArrayOutputStream.class); setImplementation(PrintStream.class, Dummies.InMemoryPrintStream.class); setImplementation(PrintWriter.class, Dummies.InMemoryPrintWriter.class); setImplementation(Queue.class, ArrayDeque.class); setImplementation(Random.class, Dummies.DeterministicRandom.class);
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Apr 17 16:33:44 GMT 2024 - 21K bytes - Viewed (1) -
android/guava-testlib/src/com/google/common/testing/ArbitraryInstances.java
setImplementation(Deque.class, ArrayDeque.class); setImplementation(OutputStream.class, ByteArrayOutputStream.class); setImplementation(PrintStream.class, Dummies.InMemoryPrintStream.class); setImplementation(PrintWriter.class, Dummies.InMemoryPrintWriter.class); setImplementation(Queue.class, ArrayDeque.class); setImplementation(Random.class, Dummies.DeterministicRandom.class);
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Apr 17 16:33:44 GMT 2024 - 20.5K 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) -
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 Apr 28 03:35:10 GMT 2024 - Last Modified: Fri Apr 12 10:50:18 GMT 2024 - 21.3K 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) -
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)