Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 49 for eventListeners (0.06 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top