- Sort Score
- Result 10 results
- Languages All
Results 161 - 170 of 228 for dequeue (0.08 sec)
-
okhttp/src/jvmTest/kotlin/okhttp3/OkHttpClientTest.kt
.build() assertThat(okHttpClient.protocols.size).isEqualTo(1) assertThat(okHttpClient.protocols[0]).isEqualTo(Protocol.H2_PRIOR_KNOWLEDGE) } @Test fun nullDefaultProxySelector() { server!!.enqueue(MockResponse(body = "abc")) ProxySelector.setDefault(null) val client = clientTestRule.newClient() val request = Request(server!!.url("/")) val response = client.newCall(request).execute()
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Jun 18 12:28:21 UTC 2025 - 13.4K bytes - Viewed (1) -
android/guava/src/com/google/common/io/Closer.java
import com.google.common.annotations.VisibleForTesting; import com.google.errorprone.annotations.CanIgnoreReturnValue; import java.io.Closeable; import java.io.IOException; import java.util.ArrayDeque; import java.util.Deque; import java.util.logging.Level; import org.jspecify.annotations.Nullable; /** * A {@link Closeable} that collects {@code Closeable} resources and closes them all when it is
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 10.3K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskQueue.kt
/** * Schedules [task] for execution in [delayNanos]. A task may only have one future execution * scheduled. If the task is already in the queue, the earliest execution time is used. * * The target execution time is implemented on a best-effort basis. If another task in this queue * is running when that time is reached, that task is allowed to complete before this task is
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed May 28 23:28:25 UTC 2025 - 7.3K bytes - Viewed (0) -
android/guava-testlib/test/com/google/common/testing/ArbitraryInstancesTest.java
import java.util.Currency; import java.util.Deque; import java.util.HashMap; import java.util.Iterator; import java.util.LinkedList; 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.PriorityQueue; import java.util.Queue; import java.util.Random; import java.util.Set;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jul 16 17:42:14 UTC 2025 - 21.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/indexer/IndexUpdater.java
/** Service for managing crawled document data */ @Resource protected DataService<OpenSearchAccessResult> dataService; /** Service for managing URL crawling queue */ @Resource protected UrlQueueService<OpenSearchUrlQueue> urlQueueService; /** Service for URL filtering operations */ @Resource protected UrlFilterService urlFilterService;
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 32.7K bytes - Viewed (0) -
okhttp-tls/README.md
.heldCertificate(serverCertificate) .build(); MockWebServer server = new MockWebServer(); server.useHttps(serverCertificates.sslSocketFactory(), false); server.requestClientAuth(); server.enqueue(new MockResponse()); // Create a client certificate and a client that uses it. HeldCertificate clientCertificate = new HeldCertificate.Builder() .commonName("ianmalcolm") .signedBy(rootCertificate)
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon Jul 07 19:32:33 UTC 2025 - 9.1K bytes - Viewed (0) -
guava-testlib/test/com/google/common/testing/ArbitraryInstancesTest.java
assertTrue(ArbitraryInstances.get(NavigableMap.class).isEmpty()); assertTrue(ArbitraryInstances.get(LinkedList.class).isEmpty()); assertTrue(ArbitraryInstances.get(Deque.class).isEmpty()); assertTrue(ArbitraryInstances.get(Queue.class).isEmpty()); assertTrue(ArbitraryInstances.get(PriorityQueue.class).isEmpty()); assertTrue(ArbitraryInstances.get(BitSet.class).isEmpty());
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jul 16 17:42:14 UTC 2025 - 22.3K bytes - Viewed (0) -
docs/metrics/prometheus/list.md
| `minio_node_ilm_transition_active_tasks` | Number of active ILM transition tasks. | | `minio_node_ilm_transition_pending_tasks` | Number of pending ILM transition tasks in the queue. |
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 43.4K bytes - Viewed (0) -
cmd/metrics-v3-cluster-notification.go
notificationEventsSkippedTotalMD = NewCounterMD(notificationEventsSkippedTotal, "Events that were skipped to be sent to the targets due to the in-memory queue being full") ) // loadClusterNotificationMetrics - `MetricsLoaderFn` for cluster notification metrics. func loadClusterNotificationMetrics(_ context.Context, m MetricValues, _ *metricsCache) error {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Wed Apr 24 04:10:35 UTC 2024 - 2.2K bytes - Viewed (0) -
cmd/metrics-v3-logger-webhook.go
webhookFailedMessagesMD = NewCounterMD(webhookFailedMessages, "Number of messages that failed to send", allWebhookLabels...) webhookQueueLengthMD = NewGaugeMD(webhookQueueLength, "Webhook queue length", allWebhookLabels...) webhookTotalMessagesMD = NewCounterMD(webhookTotalMessages, "Total number of messages sent to this target", allWebhookLabels...) )
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue May 14 07:27:33 UTC 2024 - 2K bytes - Viewed (0)