- Sort Score
- Num 10 results
- Language All
Results 151 - 160 of 318 for dequeue (0.04 seconds)
-
guava/src/com/google/common/collect/ConsumingQueueIterator.java
import java.util.Queue; import org.jspecify.annotations.Nullable; /** * An Iterator implementation which draws elements from a queue, removing them from the queue as it * iterates. This class is not thread safe. */ @GwtCompatible final class ConsumingQueueIterator<T extends @Nullable Object> extends AbstractIterator<T> { private final Queue<T> queue; ConsumingQueueIterator(Queue<T> queue) {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 1.4K bytes - Click Count (0) -
okhttp-logging-interceptor/src/test/java/okhttp3/logging/LoggingEventListenerTest.kt
handshakeCertificates.trustManager, ).retryOnConnectionFailure(false) .build() url = server.url("/") } @Test fun get() { assumeNotWindows() server.enqueue( MockResponse .Builder() .body("Hello!") .setHeader("Content-Type", PLAIN) .build(), ) val response = client.newCall(request().build()).execute()Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Fri Jun 20 11:46:46 GMT 2025 - 10.2K bytes - Click Count (0) -
docs/fr/docs/tutorial/request-form-models.md
{* ../../docs_src/request_form_models/tutorial001_an_py310.py hl[9:11,15] *} **FastAPI** va **extraire** les données pour **chaque champ** à partir des **données de formulaire** de la requête et vous fournir le modèle Pydantic que vous avez défini. ## Consulter les documents { #check-the-docs } Vous pouvez le vérifier dans l'interface des documents à `/docs` : <div class="screenshot">Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 19 18:37:13 GMT 2026 - 2.5K bytes - Click Count (0) -
samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/ClientAndServer.java
MockWebServer server = new MockWebServer(); server.setServerSocketFactory(new UnixDomainServerSocketFactory(socketFile)); server.setProtocols(Collections.singletonList(Protocol.H2_PRIOR_KNOWLEDGE)); server.enqueue(new MockResponse().setBody("hello")); server.start(); OkHttpClient client = new OkHttpClient.Builder() .socketFactory(new UnixDomainSocketFactory(socketFile))Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Mon Dec 24 03:46:30 GMT 2018 - 2.1K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Call.kt
* * @throws IllegalStateException when the call has already been executed. */ fun enqueue(responseCallback: Callback) /** Cancels the request, if possible. Requests that are already complete cannot be canceled. */ fun cancel() /** * Returns true if this call has been either [executed][execute] or [enqueued][enqueue]. It is an * error to execute a call more than once. */ fun isExecuted(): Boolean
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Nov 05 18:28:35 GMT 2025 - 6.8K bytes - Click Count (0) -
docs/features/events.md
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Mar 15 09:01:42 GMT 2026 - 7.7K bytes - Click Count (0) -
android/guava/src/com/google/common/eventbus/Dispatcher.java
// This dispatcher matches the original dispatch behavior of EventBus. /** Per-thread queue of events to dispatch. */ @SuppressWarnings("ThreadLocalUsage") // Each Dispatcher needs its own state. private final ThreadLocal<Queue<Event>> queue = new ThreadLocal<Queue<Event>>() { @Override protected Queue<Event> initialValue() { return new ArrayDeque<>(); } };Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue May 13 17:27:14 GMT 2025 - 7.4K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealCall.kt
return getResponseWithInterceptorChain() } finally { client.dispatcher.finished(this) } } override fun enqueue(responseCallback: Callback) { check(executed.compareAndSet(false, true)) { "Already Executed" } callStart() client.dispatcher.enqueue(AsyncCall(responseCallback)) } override fun isExecuted(): Boolean = executed.get() private fun callStart() {
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Jan 11 12:06:21 GMT 2026 - 19.5K bytes - Click Count (0) -
samples/compare/src/test/kotlin/okhttp3/compare/ApacheHttpClientTest.kt
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Feb 04 20:23:14 GMT 2026 - 2.3K bytes - Click Count (0) -
docs/fr/docs/index.md
 ## Mettre à niveau l'exemple { #example-upgrade } Modifiez maintenant le fichier `main.py` pour recevoir un corps depuis une requête `PUT`. Déclarez le corps en utilisant les types Python standard, grâce à Pydantic. ```Python hl_lines="2 7-10 23-25" from fastapi import FastAPI from pydantic import BaseModel app = FastAPI()Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 19 18:37:13 GMT 2026 - 23.8K bytes - Click Count (0)