- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 228 for dequeue (0.04 sec)
-
okhttp-sse/api/okhttp-sse.api
public abstract fun cancel ()V public static fun enqueue (Lokhttp3/Call;Lokhttp3/sse/EventSourceListener;)Lokhttp3/sse/EventSource; public static fun process (Lokhttp3/Response;Lokhttp3/sse/EventSourceListener;)V public abstract fun request ()Lokhttp3/Request; } public final class okhttp3/sse/EventSource$Companion { public final fun enqueue (Lokhttp3/Call;Lokhttp3/sse/EventSourceListener;)Lokhttp3/sse/EventSource;
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 30 11:47:47 UTC 2025 - 1.9K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/WebSocket.kt
* system or network intermediaries. This method returns 0 if no messages are waiting in the * queue. If may return a nonzero value after the web socket has been canceled; this indicates * that enqueued messages were not transmitted. */ fun queueSize(): Long /** * Attempts to enqueue `text` to be UTF-8 encoded and sent as a the data of a text (type `0x1`) * message. *
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 5.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/ForwardingDequeTest.java
new ForwardingWrapperTester() .testForwarding( Deque.class, new Function<Deque, Deque<?>>() { @Override public Deque<?> apply(Deque delegate) { return wrap((Deque<?>) delegate); } }); } private static <T> Deque<T> wrap(Deque<T> delegate) { return new ForwardingDeque<T>() { @Override
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 18:46:00 UTC 2025 - 1.5K bytes - Viewed (0) -
Makefile
@echo "Running $@ check" @$(GOLANGCI) run --build-tags kqueue --timeout=10m --config ./.golangci.yml @command typos && typos ./ || echo "typos binary is not found.. skipping.." lint-fix: getdeps ## runs golangci-lint suite of linters with automatic fixes @echo "Running $@ check" @$(GOLANGCI) run --build-tags kqueue --timeout=10m --config ./.golangci.yml --fix check: test
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Apr 27 00:44:22 UTC 2025 - 11.2K bytes - Viewed (0) -
okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourcesHttpTest.kt
} @Test fun failureWith401IsReadable() { server.enqueue( MockResponse( code = 401, body = "{\"error\":{\"message\":\"No auth credentials found\",\"code\":401}}", headers = Headers.headersOf("content-type", "application/json"), ), ) server.enqueue( MockResponse( body = """ |data: hey |
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 30 13:49:38 UTC 2025 - 3.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/SynchronizedDequeTest.java
protected Deque<String> create() { TestDeque<String> inner = new TestDeque<>(); Deque<String> outer = Synchronized.deque(inner, inner.mutex); outer.add("foo"); // necessary because we try to remove elements later on return outer; } private static final class TestDeque<E> implements Deque<E> { private final Deque<E> delegate = new LinkedList<>();
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jul 16 17:42:14 UTC 2025 - 7.4K bytes - Viewed (0) -
mockwebserver/src/test/java/mockwebserver3/MockResponseSniTest.kt
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Jun 18 12:28:21 UTC 2025 - 6.3K bytes - Viewed (0) -
src/main/resources/fess_message_fr.properties
errors.failed_to_delete_doc_in_admin = Échec de la suppression d'un document. errors.failed_to_send_testmail=Échec de l'envoi d'un e-mail de test. errors.invalid_query_unknown = La requête spécifiée a une condition inconnue. errors.invalid_query_parse_error = La requête donnée n'est pas valide. errors.invalid_query_sort_value = Le tri spécifié {0} n'est pas valide. errors.invalid_query_unsupported_sort_field = Le tri spécifié {0} n'est pas pris en charge.
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Jul 05 02:36:47 UTC 2025 - 13.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
assertEquals(5, runnable.count); assertEquals(0, delegate.getQueue().size()); runnable = new ThrowingRunnable(5, ex); future = service.scheduleWithFixedDelay(runnable, 1, 1, MILLISECONDS); assertExecutionException(future, ex); assertEquals(5, runnable.count); assertEquals(0, delegate.getQueue().size()); } public void testListeningDecorator_cancelled() throws Exception {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 18:46:00 UTC 2025 - 28K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/CacheCorruptionTest.kt
server.useHttps(handshakeCertificates.sslSocketFactory()) server.enqueue( MockResponse( headers = headersOf( "Last-Modified", formatDate(-1, TimeUnit.HOURS)!!, "Expires", formatDate(1, TimeUnit.HOURS)!!, ), body = "ABC.1", ), ) server.enqueue( MockResponse( headers = headersOf(
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Jun 18 12:28:21 UTC 2025 - 6K bytes - Viewed (0)