- Sort Score
- Num 10 results
- Language All
Results 141 - 150 of 318 for dequeue (0.04 seconds)
-
guava-testlib/src/com/google/common/testing/TearDownStack.java
import com.google.common.annotations.VisibleForTesting; import com.google.errorprone.annotations.concurrent.GuardedBy; import java.util.ArrayDeque; import java.util.ArrayList; import java.util.Deque; import java.util.List; import java.util.logging.Level; import java.util.logging.Logger; import org.jspecify.annotations.NullMarked; /** * A {@code TearDownStack} contains a stack of {@link TearDown} instances.Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Oct 01 13:14:50 GMT 2025 - 2.7K bytes - Click Count (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/FailingCall.kt
import kotlin.reflect.KClass import okio.Timeout open class FailingCall : Call { override fun request(): Request = error("unexpected") override fun execute(): Response = error("unexpected") override fun enqueue(responseCallback: Callback): Unit = error("unexpected") override fun cancel(): Unit = error("unexpected") override fun isExecuted(): Boolean = error("unexpected")Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Nov 05 18:28:35 GMT 2025 - 1.6K bytes - Click Count (0) -
docs/fr/docs/advanced/wsgi.md
Assurez-vous simplement que le package `a2wsgi` est installé et importez `WSGIMiddleware` correctement depuis `a2wsgi`. /// ## Vérifiez { #check-it } Désormais, chaque requête sous le chemin `/v1/` sera gérée par l'application Flask. Et le reste sera géré par **FastAPI**. Si vous l'exécutez et allez à [http://localhost:8000/v1/](http://localhost:8000/v1/) vous verrez la réponse de Flask :Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 19 18:37:13 GMT 2026 - 1.6K bytes - Click Count (0) -
buildscripts/cross-compile.sh
printf -- "--> %15s:%s\n" "${osarch}" "${package}" # go build -trimpath to build the binary. export GOOS=$os export GOARCH=$arch export GO111MODULE=on go build -trimpath -tags kqueue -o /dev/null } function main() { echo "Testing builds for OS/Arch: ${SUPPORTED_OSARCH}" for each_osarch in ${SUPPORTED_OSARCH}; do _build "${each_osarch}" done }Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Jun 08 16:12:05 GMT 2025 - 972 bytes - Click Count (0) -
samples/compare/src/test/kotlin/okhttp3/compare/OkHttpClientTest.kt
*/ class OkHttpClientTest { @JvmField @RegisterExtension val platform = PlatformRule() @StartStop private val server = MockWebServer() @Test fun get() { server.enqueue(MockResponse(body = "hello, OkHttp")) val client = OkHttpClient() val request = Request .Builder() .url(server.url("/")) .header("Accept", "text/plain") .build()Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Jun 18 12:28:21 GMT 2025 - 1.9K bytes - Click Count (0) -
samples/guide/src/main/java/okhttp3/recipes/AsynchronousGet.java
public void run() throws Exception { Request request = new Request.Builder() .url("http://publicobject.com/helloworld.txt") .build(); client.newCall(request).enqueue(new Callback() { @Override public void onFailure(Call call, IOException e) { e.printStackTrace(); } @Override public void onResponse(Call call, Response response) throws IOException {
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun May 22 01:29:42 GMT 2016 - 1.9K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/LoomTest.kt
} private fun newVirtualThreadPerTaskExecutor(): ExecutorService = Executors::class.java.getMethod("newVirtualThreadPerTaskExecutor").invoke(null) as ExecutorService @Test fun testRequest() { server.enqueue(MockResponse()) val request = Request(server.url("/")) client.newCall(request).execute().use { assertThat(it.code).isEqualTo(200) } } @Test fun testIfSupported() {
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Jun 18 12:28:21 GMT 2025 - 2K bytes - Click Count (0) -
src/main/java/org/codelibs/core/misc/DisposableUtil.java
import static org.codelibs.core.collection.CollectionsUtil.newLinkedList; import static org.codelibs.core.misc.AssertionUtil.assertArgumentNotNull; import java.beans.Introspector; import java.util.Deque; /** * Utility class for disposing of resources at the end of an application. * <p> * If there are resources that must be disposed of at the end of the application,
Created: Fri Apr 03 20:58:12 GMT 2026 - Last Modified: Thu Feb 12 12:10:45 GMT 2026 - 3.1K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/EvictingQueue.java
import java.util.Collection; import java.util.Queue; /** * A non-blocking queue which automatically evicts elements from the head of the queue when * attempting to add new elements onto the queue and it is full. This queue orders elements FIFO * (first-in-first-out). This data structure is logically equivalent to a circular buffer (i.e., * cyclic buffer or ring buffer). *
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Feb 13 17:34:21 GMT 2025 - 4.6K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/collect/MinMaxPriorityQueueTest.java
assertEquals(6, queue.size()); assertEquals(8, queue.capacity()); checkUnbounded(queue); checkNatural(queue); } public void testCreation_maximumSize_withContents() { MinMaxPriorityQueue<Integer> queue = rawtypeToWildcard(MinMaxPriorityQueue.maximumSize(42)).create(NUMBERS); assertEquals(6, queue.size()); assertEquals(11, queue.capacity()); assertEquals(42, queue.maximumSize);
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 13:11:08 GMT 2026 - 36.2K bytes - Click Count (0)