- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 44 for ArrayDeque (0.22 sec)
-
okhttp-sse/src/test/java/okhttp3/sse/internal/ServerSentEventIteratorTest.kt
import assertk.assertions.isEqualTo import java.util.ArrayDeque import java.util.Deque import okio.Buffer import org.junit.jupiter.api.AfterEach import org.junit.jupiter.api.Test class ServerSentEventIteratorTest { /** Either [Event] or [Long] items for events and retry changes, respectively. */ private val callbacks: Deque<Any> = ArrayDeque() @AfterEach fun after() { assertThat(callbacks).isEmpty()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.4K bytes - Viewed (0) -
analysis/analysis-api-fe10/src/org/jetbrains/kotlin/analysis/api/descriptors/components/KtFe10TypeProvider.kt
for (type in upperBounds) { val mappingForType = type.toTypeArgumentMapping() ?: continue val queue = ArrayDeque<TypeArgumentMapping>() queue.addLast(mappingForType) while (queue.isNotEmpty()) { val (typeParameterOwner, mapping) = queue.removeFirst()
Plain Text - Registered: Fri Apr 26 08:18:10 GMT 2024 - Last Modified: Mon Jan 29 09:37:59 GMT 2024 - 23.3K bytes - Viewed (0) -
android/guava/src/com/google/common/io/ByteStreams.java
import java.io.OutputStream; import java.nio.ByteBuffer; import java.nio.channels.FileChannel; import java.nio.channels.ReadableByteChannel; import java.nio.channels.WritableByteChannel; import java.util.ArrayDeque; import java.util.Arrays; import java.util.Queue; import javax.annotation.CheckForNull; import org.checkerframework.checker.nullness.qual.Nullable; /**
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Jan 17 18:59:58 GMT 2024 - 29.7K bytes - Viewed (0) -
build-logic/kotlin-dsl-shared-runtime/src/main/kotlin/org/gradle/kotlin/dsl/internal/sharedruntime/codegen/ApiTypeProvider.kt
if (!hasSuperType) return true fun ArrayDeque<String>.addSuperTypesOf(classNode: ClassNode) { classNode.interfaces.forEach { push(it) } if (classNode.superName != null) push(classNode.superName) } val superTypeStack = ArrayDeque<String>().apply { addSuperTypesOf(delegate) }
Plain Text - Registered: Wed Feb 28 11:36:09 GMT 2024 - Last Modified: Tue Feb 06 19:56:10 GMT 2024 - 20.8K 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) -
analysis/analysis-api-fe10/src/org/jetbrains/kotlin/analysis/api/descriptors/utils/InlineDelegatedPropertyAccessorsAnalyzer.kt
// As it's basically a DAG traversal, we can keep a queue instead of making recursive calls. val allFiles = this val filesQueueToAnalyze = ArrayDeque(allFiles) val collector = InlineFunctionsCollector(allFiles.first().project, reifiedInlineFunctionsOnly = false) { declaration -> val containingFile = declaration.containingKtFile
Plain Text - Registered: Fri Apr 26 08:18:10 GMT 2024 - Last Modified: Tue Aug 29 23:55:31 GMT 2023 - 3.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java
import com.google.errorprone.annotations.concurrent.GuardedBy; import com.google.errorprone.annotations.concurrent.LazyInit; import com.google.j2objc.annotations.RetainedWith; import java.util.ArrayDeque; import java.util.Deque; import java.util.concurrent.Executor; import java.util.concurrent.RejectedExecutionException; import java.util.logging.Level; import javax.annotation.CheckForNull; /**
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 10.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt
private var streams: Streams? = null /** Outgoing pongs in the order they should be written. */ private val pongQueue = ArrayDeque<ByteString>() /** Outgoing messages and close frames in the order they should be written. */ private val messageAndCloseQueue = ArrayDeque<Any>() /** The total size in bytes of enqueued but not yet transmitted messages. */ private var queueSize = 0L
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 01 14:21:25 GMT 2024 - 22.1K bytes - Viewed (0) -
android/guava/src/com/google/common/io/Closer.java
import com.google.common.annotations.VisibleForTesting; import com.google.errorprone.annotations.CanIgnoreReturnValue; import java.io.Closeable; import java.io.IOException; import java.lang.reflect.Method; import java.util.ArrayDeque; import java.util.Deque; import java.util.logging.Level; import javax.annotation.CheckForNull; import org.checkerframework.checker.nullness.qual.Nullable; /**
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Mar 06 15:15:46 GMT 2024 - 11.9K bytes - Viewed (0)