- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for DispatcherQueueEnd (0.53 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)