- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 147 for eventbus (0.04 sec)
-
docs/features/events.md

Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Sun Feb 06 02:19:09 UTC 2022 - 7.7K bytes - Viewed (0) -
docs/assets/images/events@2x.png
events@2x.png...
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Sun Feb 06 02:19:09 UTC 2022 - 164.7K bytes - Viewed (0) -
docs/features/caching.md
maxSize = 50L * 1024L * 1024L // 50 MiB )) .build() ``` ## EventListener events Cache Events are exposed via the EventListener API. Typical scenarios are below. ### Cache Hit In the ideal scenario the cache can fulfill the request without any conditional call to the network. This will skip the normal events such as DNS, connecting to the network, and downloading the response body.Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Sun Feb 06 02:19:09 UTC 2022 - 3.1K bytes - Viewed (1) -
android/guava/src/com/google/common/util/concurrent/ListenerCallQueue.java
* #enqueue enqueueing} and then {@linkplain #dispatch dispatching} events. * * <p>The API of this class is designed to make it easy to achieve the following properties * * <ul> * <li>Multiple events for the same listener are never dispatched concurrently. * <li>Events for the different listeners are dispatched concurrently. * <li>All events for a given listener dispatch on the provided executor.Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 8.1K bytes - Viewed (0) -
mkdocs.yml
# Redirect all feature pages to features/* 'caching.md': 'features/caching.md' 'calls.md': 'features/calls.md' 'connections.md': 'features/connections.md' 'events.md': 'features/events.md' 'https.md': 'features/events.md' 'interceptors.md': 'features/interceptors.md' 'r8_proguard.md': 'features/r8_proguard.md' # Redirect all Security pages to security/*Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Thu Nov 21 07:19:31 UTC 2024 - 3.9K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ListenerCallQueue.java
* #enqueue enqueueing} and then {@linkplain #dispatch dispatching} events. * * <p>The API of this class is designed to make it easy to achieve the following properties * * <ul> * <li>Multiple events for the same listener are never dispatched concurrently. * <li>Events for the different listeners are dispatched concurrently. * <li>All events for a given listener dispatch on the provided executor.Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 8.1K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http/CancelTest.kt
cancelLatch.await() val events = eventRecorder.eventSequence.filter { isConnectionEvent(it) }.map { it.name } eventRecorder.clearAllEvents() assertThat(events).startsWith("CallStart", "ConnectStart", "ConnectEnd", "ConnectionAcquired") if (cancelMode == CANCEL) { assertThat(events).contains("Canceled") } else { assertThat(events).doesNotContain("Canceled") }Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Tue Nov 04 19:13:52 UTC 2025 - 9.4K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/FakeRoutePlanner.kt
} canceled -> { events += "plan $id TCP connect canceled" ConnectResult(this, nextPlan = connectTcpNextPlan, throwable = IOException("canceled")) } connectTcpNextPlan != null -> { events += "plan $id needs follow-up" ConnectResult(this, nextPlan = connectTcpNextPlan) } else -> { events += "plan $id TCP connected"Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Tue Oct 07 21:55:03 UTC 2025 - 6.1K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/EventListener.kt
* request body start and end events occur within the response header events. Similarly, * [duplex calls][RequestBody.isDuplex] interleave the request and response bodies. * * Since connections may be reused, the proxy selection, DNS, and connect events may not be present * for a call. In future releases of OkHttp these events may also occur concurrently to permit
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/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketRecorder.kt
} /** Expose this recorder as a frame callback and shim in "ping" events. */ fun asFrameCallback() = object : WebSocketReader.FrameCallback { override fun onReadMessage(text: String) { events.add(Message(string = text)) } override fun onReadMessage(bytes: ByteString) { events.add(Message(bytes = bytes)) }
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 6.8K bytes - Viewed (0)