Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 61 - 70 of 318 for dequeue (0.06 seconds)

  1. android/guava-testlib/src/com/google/common/collect/testing/testers/QueueElementTester.java

      @CollectionSize.Require(ZERO)
      public void testElement_empty() {
        assertThrows(NoSuchElementException.class, () -> getQueue().element());
        expectUnchanged();
      }
    
      @CollectionSize.Require(ONE)
      public void testElement_size1() {
        assertEquals("size1Queue.element() should return first element", e0(), getQueue().element());
        expectUnchanged();
      }
    
      @CollectionFeature.Require(KNOWN_ORDER)
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Nov 14 23:40:07 GMT 2024
    - 2.4K bytes
    - Click Count (0)
  2. android/guava-testlib/src/com/google/common/collect/testing/testers/QueuePeekTester.java

      @CollectionSize.Require(ZERO)
      public void testPeek_empty() {
        assertNull("emptyQueue.peek() should return null", getQueue().peek());
        expectUnchanged();
      }
    
      @CollectionSize.Require(ONE)
      public void testPeek_size1() {
        assertEquals("size1Queue.peek() should return first element", e0(), getQueue().peek());
        expectUnchanged();
      }
    
      @CollectionFeature.Require(KNOWN_ORDER)
      @CollectionSize.Require(SEVERAL)
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Nov 14 23:40:07 GMT 2024
    - 2.3K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/util/concurrent/ListenerCallQueue.java

       */
      public void enqueue(Event<L> event) {
        enqueueHelper(event, event);
      }
    
      /**
       * Enqueues an event to be run on currently known listeners, with a label.
       *
       * @param event the callback to execute on {@link #dispatch}
       * @param label a description of the event to use in the case of an error
       */
      public void enqueue(Event<L> event, String label) {
        enqueueHelper(event, label);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue May 13 17:27:14 GMT 2025
    - 8.1K bytes
    - Click Count (0)
  4. guava-testlib/src/com/google/common/collect/testing/testers/QueuePeekTester.java

      @CollectionSize.Require(ZERO)
      public void testPeek_empty() {
        assertNull("emptyQueue.peek() should return null", getQueue().peek());
        expectUnchanged();
      }
    
      @CollectionSize.Require(ONE)
      public void testPeek_size1() {
        assertEquals("size1Queue.peek() should return first element", e0(), getQueue().peek());
        expectUnchanged();
      }
    
      @CollectionFeature.Require(KNOWN_ORDER)
      @CollectionSize.Require(SEVERAL)
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Nov 14 23:40:07 GMT 2024
    - 2.3K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/util/concurrent/AbstractService.java

      private void enqueueStartingEvent() {
        listeners.enqueue(STARTING_EVENT);
      }
    
      private void enqueueRunningEvent() {
        listeners.enqueue(RUNNING_EVENT);
      }
    
      private void enqueueStoppingEvent(State from) {
        if (from == State.STARTING) {
          listeners.enqueue(STOPPING_FROM_STARTING_EVENT);
        } else if (from == State.RUNNING) {
          listeners.enqueue(STOPPING_FROM_RUNNING_EVENT);
        } else {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Feb 19 21:24:11 GMT 2025
    - 20.3K bytes
    - Click Count (0)
  6. okhttp/src/jvmTest/kotlin/okhttp3/InsecureForHostTest.kt

      }
    
      @Test fun `untrusted host in insecureHosts connects successfully`() {
        val serverCertificates = platform.localhostHandshakeCertificates()
        server.useHttps(serverCertificates.sslSocketFactory())
        server.enqueue(MockResponse())
    
        val clientCertificates =
          HandshakeCertificates
            .Builder()
            .addPlatformTrustedCertificates()
            .addInsecureHost(server.hostName)
            .build()
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Jun 18 12:28:21 GMT 2025
    - 4.2K bytes
    - Click Count (0)
  7. mockwebserver/src/main/kotlin/mockwebserver3/QueueDispatcher.kt

        // If take() returned because we're shutting down, then enqueue another dead letter so that any
        // other threads waiting on take() will also return.
        if (result == DEAD_LETTER) responseQueue.add(DEAD_LETTER)
    
        return result
      }
    
      public override fun peek(): MockResponse = responseQueue.peek() ?: failFastResponse ?: super.peek()
    
      public open fun enqueue(response: MockResponse) {
        responseQueue.add(response)
      }
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sat Jun 14 16:09:26 GMT 2025
    - 2.9K bytes
    - Click Count (0)
  8. docs/fr/docs/tutorial/path-params-numeric-validations.md

    # Paramètres de chemin et validations numériques { #path-parameters-and-numeric-validations }
    
    De la même façon que vous pouvez déclarer plus de validations et de métadonnées pour les paramètres de requête avec `Query`, vous pouvez déclarer le même type de validations et de métadonnées pour les paramètres de chemin avec `Path`.
    
    ## Importer `Path` { #import-path }
    
    Tout d'abord, importez `Path` de `fastapi`, et importez `Annotated` :
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:37:13 GMT 2026
    - 7.1K bytes
    - Click Count (0)
  9. android-test/src/androidDeviceTest/java/okhttp/android/test/OkHttpTest.kt

        enableTls()
    
        client =
          client
            .newBuilder()
            .eventListenerFactory(clientTestRule.wrap(eventRecorder))
            .build()
    
        server.enqueue(MockResponse(body = "abc1"))
        server.enqueue(MockResponse(body = "abc2"))
    
        val request = Request.Builder().url(server.url("/")).build()
    
        client.newCall(request).execute().use { response ->
          assertEquals(200, response.code)
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 29.9K bytes
    - Click Count (0)
  10. android/guava-testlib/src/com/google/common/collect/testing/testers/QueueOfferTester.java

      public void testOffer_supportedNotPresent() {
        assertTrue("offer(notPresent) should return true", getQueue().offer(e3()));
        expectAdded(e3());
      }
    
      @CollectionFeature.Require({SUPPORTS_ADD, ALLOWS_NULL_VALUES})
      public void testOffer_nullSupported() {
        assertTrue("offer(null) should return true", getQueue().offer(null));
        expectAdded((E) null);
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Nov 14 23:40:07 GMT 2024
    - 2.3K bytes
    - Click Count (0)
Back to Top