- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 166 for unqueued (0.03 sec)
-
docs/features/events.md
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sun Feb 06 02:19:09 UTC 2022 - 7.7K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)