Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 104 for dequeue (0.03 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. .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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top