Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 228 for dequeue (0.08 sec)

  1. okhttp/src/jvmTest/kotlin/okhttp3/CacheTest.kt

      fun redirectToCachedResult() {
        server.enqueue(
          MockResponse
            .Builder()
            .addHeader("Cache-Control: max-age=60")
            .body("ABC")
            .build(),
        )
        server.enqueue(
          MockResponse
            .Builder()
            .code(HttpURLConnection.HTTP_MOVED_PERM)
            .addHeader("Location: /foo")
            .build(),
        )
        server.enqueue(
          MockResponse
            .Builder()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 16 09:39:51 UTC 2025
    - 113.6K bytes
    - Viewed (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/internal/tls/ClientAuthTest.kt

        val client = buildClient(clientCert, clientIntermediateCa.certificate)
        val socketFactory = buildServerSslSocketFactory()
        server.useHttps(socketFactory)
        server.requestClientAuth()
        server.enqueue(
          MockResponse
            .Builder()
            .body("abc")
            .build(),
        )
        val call = client.newCall(Request.Builder().url(server.url("/")).build())
        val response = call.execute()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Jun 18 12:28:21 UTC 2025
    - 12.7K bytes
    - Viewed (0)
  3. 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 {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Feb 19 21:24:11 UTC 2025
    - 20.7K bytes
    - Viewed (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)
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Nov 14 23:40:07 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  5. android/guava-testlib/src/com/google/common/testing/ArbitraryInstances.java

    import java.util.Collection;
    import java.util.Comparator;
    import java.util.Currency;
    import java.util.Deque;
    import java.util.Iterator;
    import java.util.List;
    import java.util.ListIterator;
    import java.util.Locale;
    import java.util.Map;
    import java.util.NavigableMap;
    import java.util.NavigableSet;
    import java.util.Queue;
    import java.util.Random;
    import java.util.Set;
    import java.util.SortedMap;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 20.9K bytes
    - Viewed (0)
  6. android/guava-testlib/src/com/google/common/collect/testing/testers/QueuePollTester.java

      public void testPoll_empty() {
        assertNull("emptyQueue.poll() should return null", getQueue().poll());
        expectUnchanged();
      }
    
      @CollectionFeature.Require(SUPPORTS_REMOVE)
      @CollectionSize.Require(ONE)
      public void testPoll_size1() {
        assertEquals("size1Queue.poll() should return first element", e0(), getQueue().poll());
        expectMissing(e0());
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Nov 14 23:40:07 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  7. guava-testlib/src/com/google/common/collect/testing/testers/QueueRemoveTester.java

      public void testRemove_empty() {
        assertThrows(NoSuchElementException.class, () -> getQueue().remove());
        expectUnchanged();
      }
    
      @CollectionFeature.Require(SUPPORTS_REMOVE)
      @CollectionSize.Require(ONE)
      public void testRemove_size1() {
        assertEquals("size1Queue.remove() should return first element", e0(), getQueue().remove());
        expectMissing(e0());
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Nov 14 23:40:07 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  8. 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()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 10.2K bytes
    - Viewed (0)
  9. mockwebserver/src/test/java/mockwebserver3/MockWebServerTest.kt

      }
    
      @Disabled("Not actually failing where expected")
      @Test
      fun disconnectAtStart() {
        server.enqueue(
          MockResponse
            .Builder()
            .onRequestStart(CloseSocket())
            .build(),
        )
        server.enqueue(MockResponse()) // The jdk's HttpUrlConnection is a bastard.
        server.enqueue(MockResponse())
        try {
          server
            .url("/a")
            .toUrl()
            .openConnection()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sun Aug 03 22:38:00 UTC 2025
    - 28K bytes
    - Viewed (0)
  10. okhttp/src/jvmTest/kotlin/okhttp3/internal/http/CancelTest.kt

        setUp(mode)
        val responseBodySize = 8 * 1024 * 1024 // 8 MiB.
        server.enqueue(
          MockResponse
            .Builder()
            .body(
              Buffer()
                .write(ByteArray(responseBodySize)),
            ).throttleBody(64 * 1024, 125, MILLISECONDS) // 500 Kbps
            .build(),
        )
        server.enqueue(MockResponse(body = "."))
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 9.8K bytes
    - Viewed (0)
Back to top