- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 104 for dequeue (0.03 sec)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Dispatcher.kt
* calls returns to zero). * * Note: The time at which a [call][Call] is considered idle is different depending on whether it * was run [asynchronously][Call.enqueue] or [synchronously][Call.execute]. Asynchronous calls * become idle after the [onResponse][Callback.onResponse] or [onFailure][Callback.onFailure]
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed May 28 23:28:25 UTC 2025 - 8.7K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/concurrent/TaskRunnerRealBackendTest.kt
private val taskRunner = TaskRunner(backend) private val queue = taskRunner.newQueue() @AfterEach fun tearDown() { backend.shutdown() } @Test fun test() { val t1 = System.nanoTime() / 1e6 val delays = mutableListOf(TimeUnit.MILLISECONDS.toNanos(1000), -1L) queue.schedule("task", TimeUnit.MILLISECONDS.toNanos(750)) { log.put("runOnce delays.size=${delays.size}")
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 3.5K bytes - Viewed (0) -
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 Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Nov 14 23:40:07 UTC 2024 - 2.3K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/resources/mapping/queue.json
Shinsuke Sugaya <******@****.***> 1730954650 +0900
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Thu Nov 07 04:44:10 UTC 2024 - 457 bytes - Viewed (0) -
mockwebserver/README.md
// instance for every unit test. MockWebServer server = new MockWebServer(); // Schedule some responses. server.enqueue(new MockResponse.Builder() .body("hello, world!") .build()); server.enqueue(new MockResponse.Builder() .body("sup, bra?") .build()); server.enqueue(new MockResponse.Builder() .body("yo dog") .build()); // Start the server. server.start();
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Jul 19 13:40:52 UTC 2025 - 8.1K bytes - Viewed (0) -
.github/workflows/team-triage-stale.yml
name: 'Requeue stale team-triage items' on: schedule: # Execute every day at 00:05 to avoid conflicts with other workflows - cron: '5 0 * * *' permissions: {} jobs: requeue: permissions: issues: write pull-requests: write runs-on: ubuntu-latest steps: - uses: actions/stale@v10 with: operations-per-run: 50 remove-stale-when-updated: false
Registered: Wed Sep 10 11:36:15 UTC 2025 - Last Modified: Thu Sep 04 22:13:29 UTC 2025 - 836 bytes - Viewed (0) -
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 Sep 07 07:19:17 UTC 2025 - Last Modified: Sat Nov 09 16:39:20 UTC 2024 - 5.6K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt
if (plan is FailedPlan) return plan.result // Connect TCP asynchronously. tcpConnectsInFlight += plan val taskName = "$okHttpName connect ${routePlanner.address.url.redact()}" taskRunner.newQueue().schedule( object : Task(taskName) { override fun runOnce(): Long { val connectResult = try { plan.connectTcp() } catch (e: Throwable) {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 5.8K bytes - Viewed (0) -
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()
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 30 11:47:47 UTC 2025 - 8.1K bytes - Viewed (0) -
docs/fr/docs/tutorial/body.md
# Corps de la requête Quand vous avez besoin d'envoyer de la donnée depuis un client (comme un navigateur) vers votre API, vous l'envoyez en tant que **corps de requête**. Le corps d'une **requête** est de la donnée envoyée par le client à votre API. Le corps d'une **réponse** est la donnée envoyée par votre API au client. Votre API aura presque toujours à envoyer un corps de **réponse**. Mais un client n'a pas toujours à envoyer un corps de **requête**.
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sat Nov 09 16:39:20 UTC 2024 - 7.6K bytes - Viewed (0)