- Sort Score
- Result 10 results
- Languages All
Results 151 - 160 of 228 for dequeue (0.04 sec)
-
okhttp-testing-support/src/main/kotlin/okhttp3/RecordingEventListener.kt
import assertk.assertions.isInstanceOf import assertk.assertions.matchesPredicate import java.io.IOException import java.net.InetAddress import java.net.InetSocketAddress import java.net.Proxy import java.util.Deque import java.util.concurrent.ConcurrentLinkedDeque import java.util.concurrent.TimeUnit import okhttp3.CallEvent.CacheConditionalHit import okhttp3.CallEvent.CacheHit import okhttp3.CallEvent.CacheMiss
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue May 27 14:58:02 UTC 2025 - 9.5K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/TreeTraverser.java
implements PeekingIterator<T> { private final Queue<T> queue; BreadthFirstIterator(T root) { this.queue = new ArrayDeque<>(); queue.add(root); } @Override public boolean hasNext() { return !queue.isEmpty(); } @Override public T peek() { return queue.element(); } @Override public T next() {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 8.3K bytes - Viewed (0) -
docs/features/calls.md
Calls are executed in one of two ways: * **Synchronous:** your thread blocks until the response is readable. * **Asynchronous:** you enqueue the request on any thread, and get [called back](https://square.github.io/okhttp/4.x/okhttp/okhttp3/-callback/) on another thread when the response is readable.
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sun Feb 06 02:19:09 UTC 2022 - 3.9K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt
private fun ensureAllTaskQueuesIdle() { val entryTime = System.nanoTime() for (queue in TaskRunner.INSTANCE.activeQueues()) { // We wait at most 1 second, so we don't ever turn multiple lost threads into // a test timeout failure. val waitTime = (entryTime + 1_000_000_000L - System.nanoTime()) if (!queue.idleLatch().await(waitTime, TimeUnit.NANOSECONDS)) { TaskRunner.INSTANCE.withLock {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri May 30 21:28:20 UTC 2025 - 10.5K bytes - Viewed (0) -
docs/fr/docs/python-types.md
* **Définir les prérequis** : depuis les paramètres de chemins des requêtes, les entêtes, les corps, les dépendances, etc. * **Convertir des données** : depuis la requête vers les types requis. * **Valider des données** : venant de chaque requête : * Générant automatiquement des **erreurs** renvoyées au client quand la donnée est invalide. * **Documenter** l'API avec OpenAPI :
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sat Nov 09 16:39:20 UTC 2024 - 10K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/CallHandshakeTest.kt
val expectedModernTls13CipherSuites = listOf(TLS_ECDHE_ECDSA_WITH_AES_128_GCM_SHA256, TLS_AES_128_GCM_SHA256, TLS_AES_256_GCM_SHA384) @BeforeEach fun setup() { server.enqueue(MockResponse()) client = clientTestRule .newClientBuilder() .sslSocketFactory( handshakeCertificates.sslSocketFactory(), handshakeCertificates.trustManager,
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Jun 18 12:28:21 UTC 2025 - 11.2K bytes - Viewed (0) -
src/main/resources/crawler_es+crawlerConfig.xml
"http://dbflute.org/meta/lastadi10.dtd"> <components namespace="fessCrawler"> <component name="crawlerConfig" class="org.codelibs.fess.crawler.util.FessCrawlerConfig"> <property name="queueIndex">"fess_crawler.queue"</property> <property name="queueShards">5</property> <property name="queueReplicas">1</property> <property name="dataIndex">"fess_crawler.data"</property> <property name="dataShards">5</property>
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Fri Dec 03 13:06:40 UTC 2021 - 756 bytes - Viewed (0) -
okhttp-dnsoverhttps/src/main/kotlin/okhttp3/dnsoverhttps/DnsOverHttps.kt
responses: MutableList<InetAddress>, failures: MutableList<Exception>, ) { val latch = CountDownLatch(networkRequests.size) for (call in networkRequests) { call.enqueue( object : Callback { override fun onFailure( call: Call, e: IOException, ) { synchronized(failures) { failures.add(e)
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat May 10 11:15:14 UTC 2025 - 8.6K bytes - Viewed (0) -
docs/fr/docs/project-generation.md
## Modèles d'apprentissage automatique avec spaCy et FastAPI - Fonctionnalités * Intégration d'un modèle NER **spaCy**. * Formatage de requête pour **Azure Cognitive Search**. * Serveur Python web **prêt à utiliser en production** utilisant Uvicorn et Gunicorn. * Déploiement CI/CD Kubernetes pour **Azure DevOps** (AKS).
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Mon Jul 29 23:35:07 UTC 2024 - 6.7K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
task.nextExecuteNanoTime = -1L val queue = task.queue!! queue.futureTasks.remove(task) readyQueues.remove(queue) queue.activeTask = task busyQueues.add(queue) } private fun afterRun( task: Task, delayNanos: Long, completedNormally: Boolean, ) { assertLockHeld() val queue = task.queue!! check(queue.activeTask === task)
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 30 11:30:11 UTC 2025 - 10.4K bytes - Viewed (0)