Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 166 for unqueued (0.05 sec)

  1. 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() {
      ...
    });
    ```
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sun Feb 06 02:19:09 UTC 2022
    - 7.7K bytes
    - Viewed (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/LoomTest.kt

      }
    
      private fun newVirtualThreadPerTaskExecutor(): ExecutorService =
        Executors::class.java.getMethod("newVirtualThreadPerTaskExecutor").invoke(null) as ExecutorService
    
      @Test
      fun testRequest() {
        server.enqueue(MockResponse())
    
        val request = Request(server.url("/"))
    
        client.newCall(request).execute().use {
          assertThat(it.code).isEqualTo(200)
        }
      }
    
      @Test
      fun testIfSupported() {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Jun 18 12:28:21 UTC 2025
    - 2K bytes
    - Viewed (0)
  3. samples/compare/src/test/kotlin/okhttp3/compare/OkHttpClientTest.kt

     */
    class OkHttpClientTest {
      @JvmField @RegisterExtension
      val platform = PlatformRule()
    
      @StartStop
      private val server = MockWebServer()
    
      @Test fun get() {
        server.enqueue(MockResponse(body = "hello, OkHttp"))
    
        val client = OkHttpClient()
    
        val request =
          Request
            .Builder()
            .url(server.url("/"))
            .header("Accept", "text/plain")
            .build()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Jun 18 12:28:21 UTC 2025
    - 1.9K bytes
    - Viewed (0)
  4. samples/guide/src/main/java/okhttp3/recipes/AsynchronousGet.java

      public void run() throws Exception {
        Request request = new Request.Builder()
            .url("http://publicobject.com/helloworld.txt")
            .build();
    
        client.newCall(request).enqueue(new Callback() {
          @Override public void onFailure(Call call, IOException e) {
            e.printStackTrace();
          }
    
          @Override public void onResponse(Call call, Response response) throws IOException {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sun May 22 01:29:42 UTC 2016
    - 1.9K bytes
    - Viewed (0)
  5. samples/guide/src/main/java/okhttp3/recipes/HttpsServer.java

            .heldCertificate(localhostCertificate)
            .build();
        MockWebServer server = new MockWebServer();
        server.useHttps(serverCertificates.sslSocketFactory(), false);
        server.enqueue(new MockResponse());
    
        HandshakeCertificates clientCertificates = new HandshakeCertificates.Builder()
            .addTrustedCertificate(localhostCertificate.certificate())
            .build();
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Jan 02 14:04:37 UTC 2023
    - 2.1K bytes
    - Viewed (0)
  6. 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))
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Dec 24 03:46:30 UTC 2018
    - 2.1K bytes
    - Viewed (0)
  7. samples/compare/src/test/kotlin/okhttp3/compare/JavaHttpClientTest.kt

      @Test fun get() {
        // Not available
        platform.expectFailureOnJdkVersion(8)
    
        val httpClient =
          HttpClient
            .newBuilder()
            .followRedirects(NORMAL)
            .build()
    
        server.enqueue(
          MockResponse
            .Builder()
            .body("hello, Java HTTP Client")
            .build(),
        )
    
        val request =
          HttpRequest
            .newBuilder(server.url("/").toUri())
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Jun 18 12:28:21 UTC 2025
    - 2.8K bytes
    - Viewed (0)
  8. docs/metrics/prometheus/grafana/replication/minio-replication-node.json

              "interval": "1m",
              "intervalFactor": 2,
              "legendFormat": "{{server}}",
              "refId": "A"
            }
          ],
          "title": "Avg. Queued Size",
          "type": "timeseries"
        },
        {
          "datasource": {
            "type": "prometheus",
            "uid": "${DS_PROMETHEUS}"
          },
          "fieldConfig": {
            "defaults": {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Aug 04 01:46:49 UTC 2025
    - 57.5K bytes
    - Viewed (0)
  9. samples/compare/src/test/kotlin/okhttp3/compare/ApacheHttpClientTest.kt

      private val httpClient = HttpClients.createDefault()
    
      @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")
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Jun 18 12:28:21 UTC 2025
    - 2.1K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/base/FinalizableReferenceQueueTest.java

      @Test
      public void testThatFinalizerStops() {
        weaklyReferenceQueue();
        GcFinalization.awaitClear(queueReference);
      }
    
      /** If we don't keep a strong reference to the reference object, it won't be enqueued. */
      @Nullable FinalizableWeakReference<Object> reference;
    
      /** Create the FRQ in a method that goes out of scope so that we're sure it will be reclaimed. */
      private void weaklyReferenceQueue() {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 8.7K bytes
    - Viewed (0)
Back to top