Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 151 - 160 of 318 for dequeue (0.04 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. docs/features/events.md

        .url("https://www.washingtonpost.com/")
        .build();
    client.newCall(washingtonPostRequest).enqueue(new Callback() {
      ...
    });
    
    Request newYorkTimesRequest = new Request.Builder()
        .url("https://www.nytimes.com/")
        .build();
    client.newCall(newYorkTimesRequest).enqueue(new Callback() {
      ...
    });
    ```
    
    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)
  7. 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)
  8. 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)
  9. samples/compare/src/test/kotlin/okhttp3/compare/ApacheHttpClientTest.kt

      @StartStop
      private val server = MockWebServer()
    
      @AfterEach
      fun tearDown() {
        httpClient.close()
      }
    
      @Test
      fun get() {
        server.enqueue(
          MockResponse
            .Builder()
            .body("hello, Apache HttpClient 5.x")
            .build(),
        )
    
        val request = HttpGet(server.url("/").toUri())
        request.addHeader("Accept", "text/plain")
    
    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)
  10. docs/fr/docs/index.md

    ![ReDoc](https://fastapi.tiangolo.com/img/index/index-02-redoc-simple.png)
    
    ## 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)
Back to Top