Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 280 for dequeue (0.09 sec)

  1. okhttp/src/test/java/okhttp3/EventListenerTest.kt

        enableTlsWithTunnel()
        server.enqueue(
          MockResponse.Builder()
            .inTunnel()
            .code(407)
            .addHeader("Proxy-Authenticate: Basic realm=\"localhost\"")
            .addHeader("Connection: close")
            .build(),
        )
        server.enqueue(
          MockResponse.Builder()
            .inTunnel()
            .build(),
        )
        server.enqueue(MockResponse())
        client =
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 56.9K bytes
    - Viewed (2)
  2. docs/fr/docs/tutorial/query-params.md

    # Paramètres de requête
    
    Quand vous déclarez des paramètres dans votre fonction de chemin qui ne font pas partie des paramètres indiqués dans le chemin associé, ces paramètres sont automatiquement considérés comme des paramètres de "requête".
    
    {* ../../docs_src/query_params/tutorial001.py hl[9] *}
    
    La partie appelée requête (ou **query**) dans une URL est l'ensemble des paires clés-valeurs placées après le `?` , séparées par des `&`.
    
    Par exemple, dans l'URL :
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 27 17:06:01 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  3. 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);
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 20:00:30 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  4. okhttp/src/test/java/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 Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/collect/ForwardingDequeTest.java

                  public Deque<?> apply(Deque delegate) {
                    return wrap((Deque<?>) delegate);
                  }
                });
      }
    
      private static <T> Deque<T> wrap(final Deque<T> delegate) {
        return new ForwardingDeque<T>() {
          @Override
          protected Deque<T> delegate() {
            return delegate;
          }
        };
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 22 20:09:59 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  6. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  7. mockwebserver/src/test/java/mockwebserver3/MockResponseSniTest.kt

              handshakeCertificates.sslSocketFactory(),
              handshakeCertificates.trustManager,
            )
            .proxy(server.toProxyAddress())
            .build()
    
        server.enqueue(MockResponse(inTunnel = true))
        server.enqueue(MockResponse())
    
        val call =
          client.newCall(
            Request(
              url =
                server.url("/").newBuilder()
                  .host(hostnameOrIpAddress)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  8. okhttp/src/test/java/okhttp3/CallKotlinTest.kt

          }
    
          override fun writeTo(sink: BufferedSink) {
            sink.writeUtf8("<element/>")
            sink.flush()
          }
        }
    
        server.enqueue(MockResponse(code = 201))
        server.enqueue(MockResponse(code = 204))
        server.enqueue(MockResponse(code = 204))
    
        val endpointUrl = server.url("/endpoint")
    
        var request =
          Request.Builder()
            .url(endpointUrl)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  9. okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourceHttpTest.kt

            .build()
        server.enqueue(
          MockResponse.Builder()
            .headersDelay(500, TimeUnit.MILLISECONDS)
            .setHeader("content-type", "text/event-stream")
            .body("data: hey\n\n")
            .build(),
        )
        newEventSource()
        listener.assertFailure("timeout")
      }
    
      @Test
      fun retainsAccept() {
        server.enqueue(
          MockResponse.Builder()
            .body(
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Jan 14 10:20:09 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt

        webServer.enqueue(
          MockResponse.Builder()
            .code(408)
            .build(),
        )
        webServer.enqueue(
          MockResponse.Builder()
            .webSocketUpgrade(serverListener)
            .build(),
        )
        val webSocket: WebSocket = newWebSocket()
        clientListener.assertOpen()
        val server = serverListener.assertOpen()
        webSocket.send("abc")
        serverListener.assertTextMessage("abc")
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Mar 31 17:16:15 UTC 2024
    - 35.2K bytes
    - Viewed (0)
Back to top