- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 49 for eventListeners (0.06 sec)
-
okhttp/src/jvmTest/kotlin/okhttp3/ServerTruncatesRequestTest.kt
} val localClient = client.newBuilder().eventListener(eventListener).build() val call1 = localClient.newCall(Request(server.url("/"))) call1.execute().use { response -> assertThat(response.body.string()).isEqualTo("Req1") assertThat(response.handshake).isNotNull() assertThat(response.protocol == Protocol.HTTP_1_1) } eventListener.closed = true
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Jun 20 11:46:46 UTC 2025 - 9.4K bytes - Viewed (0) -
docs/features/events.md
* The performance of these calls on the underlying network. If the network’s performance isn’t sufficient, you need to either improve the network or use less of it. ### EventListener Subclass [EventListener](https://square.github.io/okhttp/3.x/okhttp/okhttp3/EventListener.html) and override methods for the events you are interested in. In a successful HTTP call with no redirects or retries the sequence of events is described by this flow.
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sun Feb 06 02:19:09 UTC 2022 - 7.7K bytes - Viewed (0) -
android-test/src/androidTest/java/okhttp/android/test/OkHttpTest.kt
response.use { assertEquals(200, response.code) } } @Test fun testEventListener() { val eventListener = RecordingEventListener() enableTls() client = client.newBuilder().eventListenerFactory(clientTestRule.wrap(eventListener)).build() server.enqueue(MockResponse(body = "abc1")) server.enqueue(MockResponse(body = "abc2"))
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 02 14:12:28 UTC 2025 - 29K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http/SocketFailureTest.kt
@StartStop private val server = MockWebServer() private var client = clientTestRule .newClientBuilder() .eventListener(listener) .build() class SocketClosingEventListener : EventListener() { var shouldClose: Boolean = false var lastSocket: Socket? = null override fun connectionAcquired( call: Call, connection: Connection, ) {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue Jul 29 21:11:09 UTC 2025 - 3K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/kt/WiresharkExample.kt
*/ @SuppressSignatureCheck class WireSharkListenerFactory( private val logFile: File, private val tlsVersions: List<TlsVersion>, private val launch: Launch? = null, ) : EventListener.Factory { override fun create(call: Call): EventListener = WireSharkKeyLoggerListener(logFile, launch == null) fun launchWireShark(): Process? { when (launch) { null -> { if (tlsVersions.contains(TLS_1_2)) {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat May 10 11:15:14 UTC 2025 - 10.9K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/ConnectionCoalescingTest.kt
val latch1 = CountDownLatch(1) val latch2 = CountDownLatch(1) val latch3 = CountDownLatch(1) val latch4 = CountDownLatch(1) val listener1: EventListener = object : EventListener() { override fun connectStart( call: Call, inetSocketAddress: InetSocketAddress, proxy: Proxy, ) { try {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jun 19 11:44:16 UTC 2025 - 19.1K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt
Logger.getLogger(TaskRunner::class.java.name).fn() Logger.getLogger("javax.net.ssl").fn() } fun wrap(eventListener: EventListener) = EventListener.Factory { ClientRuleEventListener(eventListener, ::addEvent) } fun wrap(eventListenerFactory: EventListener.Factory) = EventListener.Factory { call -> ClientRuleEventListener(eventListenerFactory.create(call), ::addEvent) } /**
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri May 30 21:28:20 UTC 2025 - 10.5K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/PrintEventsNonConcurrent.java
import java.io.IOException; import java.net.InetAddress; import java.net.InetSocketAddress; import java.net.Proxy; import java.util.List; import okhttp3.Call; import okhttp3.Connection; import okhttp3.EventListener; import okhttp3.Handshake; import okhttp3.HttpUrl; import okhttp3.OkHttpClient; import okhttp3.Protocol; import okhttp3.Request; import okhttp3.Response; /**
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sun Feb 16 23:20:49 UTC 2020 - 5.3K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/ClientRuleEventListener.kt
import java.net.Proxy import java.util.concurrent.TimeUnit class ClientRuleEventListener( val delegate: EventListener = NONE, var logger: (String) -> Unit, ) : EventListener(), EventListener.Factory { private var startNs: Long? = null override fun create(call: Call): EventListener = this override fun callStart(call: Call) { startNs = System.nanoTime()
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue May 27 14:58:02 UTC 2025 - 6.5K bytes - Viewed (0) -
okhttp-dnsoverhttps/src/test/java/okhttp3/dnsoverhttps/DnsOverHttpsTest.kt
private lateinit var dns: Dns private val cacheFs = FakeFileSystem() private val eventListener = RecordingEventListener() private val bootstrapClient = OkHttpClient .Builder() .protocols(listOf(Protocol.HTTP_2, Protocol.HTTP_1_1)) .eventListener(eventListener) .build() @BeforeEach fun setUp() { server.protocols = bootstrapClient.protocols
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Jun 18 12:28:21 UTC 2025 - 11.7K bytes - Viewed (0)