- Sort Score
- Result 10 results
- Languages All
Results 31 - 39 of 39 for EventListener (0.26 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)