Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for DispatcherQueueEnd (0.53 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-testing-support/src/main/kotlin/okhttp3/EventListenerAdapter.kt

      override fun dispatcherQueueStart(
        call: Call,
        dispatcher: Dispatcher,
      ) = onEvent(DispatcherQueueStart(System.nanoTime(), call, dispatcher))
    
      override fun dispatcherQueueEnd(
        call: Call,
        dispatcher: Dispatcher,
      ) = onEvent(DispatcherQueueEnd(System.nanoTime(), call, dispatcher))
    
      override fun proxySelectStart(
        call: Call,
        url: HttpUrl,
      ) = onEvent(ProxySelectStart(System.nanoTime(), call, url))
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Nov 04 19:13:52 UTC 2025
    - 7.1K bytes
    - Viewed (0)
  3. okhttp-logging-interceptor/src/main/kotlin/okhttp3/logging/LoggingEventListener.kt

        dispatcher: Dispatcher,
      ) {
        logWithTime("dispatcherQueueStart: $call queuedCallsCount=${dispatcher.queuedCallsCount()}")
      }
    
      override fun dispatcherQueueEnd(
        call: Call,
        dispatcher: Dispatcher,
      ) {
        logWithTime("dispatcherQueueEnd: $call queuedCallsCount=${dispatcher.queuedCallsCount()}")
      }
    
      override fun proxySelectStart(
        call: Call,
        url: HttpUrl,
      ) {
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Mon Oct 06 13:40:20 UTC 2025
    - 5.8K bytes
    - Viewed (0)
  4. okhttp-testing-support/src/main/kotlin/okhttp3/ClientRuleEventListener.kt

        call: Call,
        dispatcher: Dispatcher,
      ) {
        logWithTime("dispatcherQueueStart: queuedCallsCount=${dispatcher.queuedCallsCount()}")
      }
    
      override fun dispatcherQueueEnd(
        call: Call,
        dispatcher: Dispatcher,
      ) {
        logWithTime("dispatcherQueueEnd: queuedCallsCount=${dispatcher.queuedCallsCount()}")
      }
    
      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
    - 5.4K bytes
    - Viewed (0)
  5. 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)
  6. okhttp-logging-interceptor/api/logging-interceptor.api

    	public fun connectionAcquired (Lokhttp3/Call;Lokhttp3/Connection;)V
    	public fun connectionReleased (Lokhttp3/Call;Lokhttp3/Connection;)V
    	public fun dispatcherQueueEnd (Lokhttp3/Call;Lokhttp3/Dispatcher;)V
    	public fun dispatcherQueueStart (Lokhttp3/Call;Lokhttp3/Dispatcher;)V
    	public fun dnsEnd (Lokhttp3/Call;Ljava/lang/String;Ljava/util/List;)V
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Oct 07 15:15:46 UTC 2025
    - 4.6K bytes
    - Viewed (0)
  7. 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)
  8. okhttp-testing-support/src/main/kotlin/okhttp3/CallEvent.kt

      data class DispatcherQueueStart(
        override val timestampNs: Long,
        override val call: Call,
        val dispatcher: Dispatcher,
      ) : CallEvent()
    
      data class DispatcherQueueEnd(
        override val timestampNs: Long,
        override val call: Call,
        val dispatcher: Dispatcher,
      ) : CallEvent() {
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Mon Oct 06 13:40:20 UTC 2025
    - 7.4K bytes
    - Viewed (0)
  9. okhttp/api/jvm/okhttp.api

    	public fun connectionAcquired (Lokhttp3/Call;Lokhttp3/Connection;)V
    	public fun connectionReleased (Lokhttp3/Call;Lokhttp3/Connection;)V
    	public fun dispatcherQueueEnd (Lokhttp3/Call;Lokhttp3/Dispatcher;)V
    	public fun dispatcherQueueStart (Lokhttp3/Call;Lokhttp3/Dispatcher;)V
    	public fun dnsEnd (Lokhttp3/Call;Ljava/lang/String;Ljava/util/List;)V
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Nov 05 18:28:35 UTC 2025
    - 70.2K bytes
    - Viewed (0)
  10. 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