Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 37 for EventListener (0.12 sec)

  1. okhttp/src/main/kotlin/okhttp3/EventListener.kt

         * from this method.**
         */
        fun create(call: Call): EventListener
      }
    
      companion object {
        @JvmField
        val NONE: EventListener =
          object : EventListener() {
          }
      }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 15.2K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/connection/Exchange.kt

          trackFailure(e)
        }
        if (requestDone) {
          if (e != null) {
            eventListener.requestFailed(call, e)
          } else {
            eventListener.requestBodyEnd(call, bytesRead)
          }
        }
        if (responseDone) {
          if (e != null) {
            eventListener.responseFailed(call, e)
          } else {
            eventListener.responseBodyEnd(call, bytesRead)
          }
        }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt

      val forWebSocket: Boolean,
    ) : Call, Cloneable {
      internal val lock: ReentrantLock = ReentrantLock()
    
      private val connectionPool: RealConnectionPool = client.connectionPool.delegate
    
      internal val eventListener: EventListener = client.eventListenerFactory.create(this)
    
      private val timeout =
        object : AsyncTimeout() {
          override fun timedOut() {
            ******@****.***()
          }
        }.apply {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  4. okhttp-logging-interceptor/src/main/kotlin/okhttp3/logging/LoggingEventListener.kt

    import java.net.Proxy
    import java.util.concurrent.TimeUnit
    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
    
    /**
     * An OkHttp EventListener, which logs call events. Can be applied as an
     * [event listener factory][OkHttpClient.eventListenerFactory].
     *
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 01 11:07:32 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  5. 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 Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 27K bytes
    - Viewed (0)
  6. android-test/src/androidTest/java/okhttp/android/test/alpn/AlpnOverrideTest.kt

              listOf(
                ConnectionSpec.Builder(ConnectionSpec.MODERN_TLS)
                  .supportsTlsExtensions(false)
                  .build(),
              ),
            )
            .eventListener(
              object : EventListener() {
                override fun connectionAcquired(
                  call: Call,
                  connection: Connection,
                ) {
                  val sslSocket = connection.socket() as SSLSocket
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/internal/connection/CallConnectionUser.kt

    internal class CallConnectionUser(
      private val call: RealCall,
      private val poolConnectionListener: ConnectionListener,
      private val chain: RealInterceptorChain,
    ) : ConnectionUser {
      private val eventListener: EventListener
        get() = call.eventListener
    
      override fun addPlanToCancel(connectPlan: ConnectPlan) {
        call.plansToCancel += connectPlan
      }
    
      override fun removePlanToCancel(connectPlan: ConnectPlan) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Mar 06 17:33:38 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  8. okhttp/src/test/java/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 Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  9. okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourceHttpTest.kt

      @RegisterExtension
      val clientTestRule = OkHttpClientTestRule()
      private val eventListener = RecordingEventListener()
      private val listener = EventSourceRecorder()
      private var client =
        clientTestRule.newClientBuilder()
          .eventListenerFactory(clientTestRule.wrap(eventListener))
          .build()
    
      @BeforeEach
      fun before(server: MockWebServer) {
        this.server = server
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Jan 14 10:20:09 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  10. okhttp/src/main/kotlin/okhttp3/internal/cache/CacheInterceptor.kt

        val networkRequest = strategy.networkRequest
        val cacheResponse = strategy.cacheResponse
    
        cache?.trackResponse(strategy)
        val listener = (call as? RealCall)?.eventListener ?: EventListener.NONE
    
        if (cacheCandidate != null && cacheResponse == null) {
          // The cache candidate wasn't applicable. Close it.
          cacheCandidate.body.closeQuietly()
        }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Fri Mar 22 07:09:21 UTC 2024
    - 10.2K bytes
    - Viewed (0)
Back to top