Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for DispatcherQueueEnd (0.08 sec)

  1. okhttp/src/jvmTest/kotlin/okhttp3/DispatcherTest.kt

        assertThat(eventRecorder.eventSequence).none { it.isInstanceOf<DispatcherQueueEnd>() }
    
        dispatcher.maxRequests = 4
        executor.assertJobs("http://a/1", "http://b/1", "http://c/1", "http://a/2")
    
        val dispatcherQueueEndC1 = eventRecorder.removeUpToEvent<DispatcherQueueEnd>()
        assertThat(dispatcherQueueEndC1.call.request().url).isEqualTo("http://c/1".toHttpUrl())
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Nov 04 19:13:52 UTC 2025
    - 15.8K bytes
    - Viewed (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/EventListener.kt

          for (delegate in eventListeners) {
            delegate.dispatcherQueueStart(call, dispatcher)
          }
        }
    
        override fun dispatcherQueueEnd(
          call: Call,
          dispatcher: Dispatcher,
        ) {
          for (delegate in eventListeners) {
            delegate.dispatcherQueueEnd(call, dispatcher)
          }
        }
    
        override fun proxySelectStart(
          call: Call,
          url: HttpUrl,
        ) {
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Oct 07 21:03:04 UTC 2025
    - 24.9K bytes
    - Viewed (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Dispatcher.kt

          // publish those events for calls that have to wait.
          if (call === enqueuedCall) {
            callDispatcherQueueStart = false
          } else {
            call.call.eventListener.dispatcherQueueEnd(call.call, this)
          }
    
          if (executorIsShutdown) {
            call.failRejected()
          } else {
            call.executeOn(executorService)
          }
        }
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Oct 07 14:16:22 UTC 2025
    - 9.9K bytes
    - Viewed (0)
  4. CHANGELOG.md

        use it to compose a cache URL from the query body.
    
     *  New: Publish events when calls must wait to execute. `EventListener.dispatcherQueueStart()`
        is invoked when a call starts waiting, and `dispatcherQueueEnd()` is invoked when it's done.
    
     *  New: `Request.toCurl()` returns a copy-pasteable [curl] command consistent with Chrome’s and
        Firefox’s ‘copy as cURL’ features.
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Dec 05 16:02:59 UTC 2025
    - 36.2K bytes
    - Viewed (2)
Back to top