Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 39 of 39 for EventListener (0.26 sec)

  1. okhttp/src/test/java/okhttp3/internal/http/CancelTest.kt

                }
              },
            )
            .sslSocketFactory(
              handshakeCertificates.sslSocketFactory(),
              handshakeCertificates.trustManager,
            )
            .eventListener(listener)
            .apply {
              if (connectionType == HTTPS) {
                protocols(listOf(HTTP_1_1))
              }
            }
            .build()
        threadToCancel = Thread.currentThread()
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  2. okhttp-testing-support/src/main/kotlin/okhttp3/RecordingEventListener.kt

      /**
       * An override to ignore the normal order that is enforced.
       * EventListeners added by Interceptors will not see all events.
       */
      private val enforceOrder: Boolean = true,
    ) : EventListener() {
      val eventSequence: Deque<CallEvent> = ConcurrentLinkedDeque()
    
      private val forbiddenLocks = mutableListOf<Any>()
    
      /** The timestamp of the last taken event, used to measure elapsed time between events. */
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 9K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/Authenticator.kt

     * [RFC 2817][1]. The HTTP CONNECT request that creates this tunnel connection is special: it
     * does not participate in any [interceptors][Interceptor] or [event listeners][EventListener]. It
     * doesn't include the motivating request's HTTP headers or even its full URL; only the target
     * server's hostname is sent to the proxy.
     *
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  4. docs/changelogs/changelog_3x.md

        call.
    
        The `RequestBody.writeTo()` method may now retain a reference to the provided sink and
        hand it off to another thread to write to it after `writeTo` returns.
    
        The `EventListener` may now see requests and responses interleaved in ways not previously
        permitted. For example, a listener may receive `responseHeadersStart()` followed by
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 14:55:54 UTC 2022
    - 50.8K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/CallTest.kt

      fun connectionIsImmediatelyUnhealthy() {
        val listener: EventListener =
          object : EventListener() {
            override fun connectionAcquired(
              call: Call,
              connection: Connection,
            ) {
              connection.socket().closeQuietly()
            }
          }
        client =
          client.newBuilder()
            .eventListener(listener)
            .build()
        executeSynchronously("/")
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 10 19:46:48 UTC 2024
    - 142.5K bytes
    - Viewed (0)
  6. okhttp/src/test/java/okhttp3/DuplexTest.kt

                throw AssertionError()
              }
              super.responseHeadersEnd(call, response)
            }
          }
        client =
          client.newBuilder()
            .eventListener(listener)
            .build()
        val body =
          MockStreamHandler()
            .sendResponse("/a has moved!\n", duplexResponseSent)
            .requestIOException()
            .exhaustResponse()
        server.enqueue(
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 23.9K bytes
    - Viewed (0)
  7. okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt

        server.enqueue(
          MockResponse(body = "XXX"),
        )
        val connections: MutableList<RealConnection?> = ArrayList()
        val localClient =
          client.newBuilder().eventListener(
            object : EventListener() {
              override fun connectionAcquired(
                call: Call,
                connection: Connection,
              ) {
                connections.add(connection as RealConnection)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 11 22:09:35 UTC 2024
    - 75.3K bytes
    - Viewed (0)
  8. okhttp/src/test/java/okhttp3/internal/tls/ClientAuthTest.kt

            .build()
        var client = buildClient(clientCert, clientIntermediateCa.certificate)
        val listener = RecordingEventListener()
        client =
          client.newBuilder()
            .eventListener(listener)
            .build()
        val socketFactory = buildServerSslSocketFactory()
        server.useHttps(socketFactory)
        server.requireClientAuth()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Jan 14 10:20:09 UTC 2024
    - 12.5K bytes
    - Viewed (0)
  9. okhttp/src/test/java/okhttp3/KotlinDeprecationErrorTest.kt

        val interceptors: List<Interceptor> = client.interceptors()
        val networkInterceptors: List<Interceptor> = client.networkInterceptors()
        val eventListenerFactory: EventListener.Factory = client.eventListenerFactory()
        val proxySelector: ProxySelector = client.proxySelector()
        val cookieJar: CookieJar = client.cookieJar()
        val cache: Cache? = client.cache()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 13.3K bytes
    - Viewed (0)
Back to top