Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 83 for poll (0.75 sec)

  1. okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt

       * like [poll]. It is only usable within task faker tasks.
       */
      private inner class TaskFakerBlockingQueue<T>(
        val delegate: BlockingQueue<T>,
      ) : AbstractQueue<T>(), BlockingQueue<T> {
        override val size: Int = delegate.size
    
        private var editCount = 0
    
        override fun poll(): T = delegate.poll()
    
        override fun poll(
          timeout: Long,
          unit: TimeUnit,
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Apr 29 00:33:04 GMT 2024
    - 12.6K bytes
    - Viewed (0)
  2. doc/next/6-stdlib/1-time.md

    making it difficult to use `Reset` and `Stop` correctly.
    A visible effect of this change is that `len` and `cap` of timer channels
    now returns 0 instead of 1, which may affect programs that
    poll the length to decide whether a receive on the timer channel
    will succeed.
    Such code should use a non-blocking receive instead.
    
    These new behaviors are only enabled when the main Go program
    Plain Text
    - Registered: Tue May 07 11:14:38 GMT 2024
    - Last Modified: Fri Apr 12 20:57:18 GMT 2024
    - 1.5K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt

        synchronized(this@RealWebSocket) {
          if (failed) {
            return false // Failed web socket.
          }
    
          writer = this.writer
          pong = pongQueue.poll()
          if (pong == null) {
            messageOrClose = messageAndCloseQueue.poll()
            if (messageOrClose is Close) {
              receivedCloseCode = this.receivedCloseCode
              receivedCloseReason = this.receivedCloseReason
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Apr 01 14:21:25 GMT 2024
    - 22.1K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt

        )
    
        taskFaker.assertNoMoreTasks()
      }
    
      /**
       * This test causes two connections to become available simultaneously, one from a TCP connect and
       * one from the pool. We must take the pooled connection because by taking it from the pool, we've
       * fully acquired it.
       *
       * This test yields threads to force the decision of plan1 to be deliberate and not lucky. In
       * particular, we set up this sequence of events:
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Apr 24 04:40:49 GMT 2024
    - 20.9K bytes
    - Viewed (0)
  5. mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt

       * @return the head of the request queue
       */
      @Throws(InterruptedException::class)
      fun takeRequest(
        timeout: Long,
        unit: TimeUnit,
      ): RecordedRequest? = requestQueue.poll(timeout, unit)
    
      /**
       * Scripts [response] to be returned to a request made in sequence. The first request is
       * served by the first enqueued response; the second request by the second enqueued response; and
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sun Mar 31 17:16:15 GMT 2024
    - 37.4K bytes
    - Viewed (0)
  6. CHANGELOG/CHANGELOG-1.27.md

    - Fix: the volume is not detached after the pod and PVC objects are deleted ([#117236](https://github.com/kubernetes/kubernetes/pull/117236), [@cvvz](https://github.com/cvvz)) [SIG Storage]
    Plain Text
    - Registered: Fri May 03 09:05:14 GMT 2024
    - Last Modified: Tue Apr 16 15:20:21 GMT 2024
    - 434.3K bytes
    - Viewed (3)
  7. okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt

        // Running at time 75, the pool returns that nothing can be evicted until time 150.
        assertThat(pool.closeConnections(75L)).isEqualTo(75L)
        assertThat(pool.connectionCount()).isEqualTo(2)
    
        // Running at time 149, the pool returns that nothing can be evicted until time 150.
        assertThat(pool.closeConnections(149L)).isEqualTo(1L)
        assertThat(pool.connectionCount()).isEqualTo(2)
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Apr 24 04:40:49 GMT 2024
    - 12.7K bytes
    - Viewed (0)
  8. docs/fr/docs/fastapi-people.md

    * [Aident les autres à résoudre des problèmes (questions) dans GitHub](help-fastapi.md#aider-les-autres-a-resoudre-les-problemes-dans-github){.internal-link target=_blank}.
    * [Créent des Pull Requests](help-fastapi.md#creer-une-pull-request){.internal-link target=_blank}.
    * Review les Pull Requests, [particulièrement important pour les traductions](contributing.md#traductions){.internal-link target=_blank}.
    
    Une salve d'applaudissements pour eux. 👏 🙇
    
    Plain Text
    - Registered: Sun May 05 07:19:11 GMT 2024
    - Last Modified: Thu Apr 18 19:53:19 GMT 2024
    - 6.9K bytes
    - Viewed (0)
  9. docs/de/docs/contributing.md

    !!! tip "Tipp"
        Sie können <a href="https://help.github.com/en/github/collaborating-with-issues-and-pull-requests/commenting-on-a-pull-request" class="external-link" target="_blank">Kommentare mit Änderungsvorschlägen</a> zu vorhandenen Pull Requests hinzufügen.
    
    Plain Text
    - Registered: Sun May 05 07:19:11 GMT 2024
    - Last Modified: Sat Mar 30 23:55:23 GMT 2024
    - 16.2K bytes
    - Viewed (0)
  10. docs/en/docs/help-fastapi.md

    ## Review Pull Requests
    
    You can help me review pull requests from others.
    
    Again, please try your best to be kind. 🤗
    
    ---
    
    Here's what to keep in mind and how to review a pull request:
    
    ### Understand the problem
    
    Plain Text
    - Registered: Sun May 05 07:19:11 GMT 2024
    - Last Modified: Thu Apr 18 19:53:19 GMT 2024
    - 13.7K bytes
    - Viewed (0)
Back to top