- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 38 for connectionAcquired (0.13 sec)
-
okhttp/src/test/java/okhttp3/EventListenerTest.kt
) val response = call.execute() assertThat(response.code).isEqualTo(200) response.body.close() val connectionAcquired = listener.removeUpToEvent<ConnectionAcquired>() assertThat(connectionAcquired.call).isSameAs(call) assertThat(connectionAcquired.connection).isNotNull() } @Test fun noConnectionFoundOnFollowUp() { server.enqueue( MockResponse.Builder()
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 56.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/RouteFailureTest.kt
assertThat(clientTestRule.recordedConnectionEventTypes()).containsExactly( "ConnectStart", "ConnectEnd", "ConnectionAcquired", "NoNewExchanges", "ConnectionReleased", "ConnectionClosed", "ConnectStart", "ConnectEnd", "ConnectionAcquired", "ConnectionReleased", ) } @Test fun http2OneBadHostOneGoodNoRetryOnConnectionFailureFastFallback() {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Tue May 14 17:48:07 UTC 2024 - 11.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ConnectionListenerTest.kt
.execute().close() assertThat(listener.recordedEventTypes()).containsExactly( "ConnectStart", "ConnectEnd", "ConnectionAcquired", "ConnectionReleased", "ConnectionAcquired", "ConnectionReleased", ) } @Test @Throws(IOException::class) fun successfulEmptyH2CallEventSequence() { enableTls()
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 9.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/ConnectionListener.kt
* Invoked when a connection is released as no longer required. */ open fun connectionClosed(connection: Connection) {} /** * Invoked when a call is assigned a particular connection. */ open fun connectionAcquired( connection: Connection, call: Call, ) {} /** * Invoked when a call no longer uses a connection. */ open fun connectionReleased( connection: Connection, call: Call,
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Tue Jan 23 14:31:42 UTC 2024 - 2.2K bytes - Viewed (0) -
okhttp-logging-interceptor/src/main/kotlin/okhttp3/logging/LoggingEventListener.kt
proxy: Proxy, protocol: Protocol?, ioe: IOException, ) { logWithTime("connectFailed: $protocol $ioe") } override fun connectionAcquired( call: Call, connection: Connection, ) { logWithTime("connectionAcquired: $connection") } override fun connectionReleased( call: Call, connection: Connection, ) { logWithTime("connectionReleased") }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Apr 01 11:07:32 UTC 2024 - 5.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http/CancelTest.kt
} addAll(listOf("ConnectionAcquired", "ConnectionReleased", "CallEnd")) } assertThat(events2).isEqualTo(expectedEvents2) } private fun isConnectionEvent(it: CallEvent?) = it is CallStart || it is CallEnd || it is ConnectStart || it is ConnectEnd || it is ConnectionAcquired || it is ConnectionReleased || it is Canceled ||
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/src/main/kotlin/okhttp3/EventListener.kt
* to the [Call.request] is a redirect to a different address. */ open fun connectionAcquired( call: Call, connection: Connection, ) { } /** * Invoked after a connection has been released for the `call`. * * This method is always invoked after [connectionAcquired]. * * This can be invoked more than 1 time for a single [Call]. For example, if the response to the
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 15.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/CallConnectionUser.kt
override fun connectionConnectEnd( connection: Connection, route: Route, ) { poolConnectionListener.connectEnd(connection, route, call) } override fun connectionAcquired(connection: Connection) { eventListener.connectionAcquired(call, connection) } override fun acquireConnectionNoEvents(connection: RealConnection) { call.acquireConnectionNoEvents(connection) }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Wed Mar 06 17:33:38 UTC 2024 - 3.6K bytes - Viewed (0) -
android-test/src/androidTest/java/okhttp/android/test/OkHttpTest.kt
client = OkHttpClient.Builder() .eventListenerFactory( clientTestRule.wrap( object : EventListener() { override fun connectionAcquired( call: Call, connection: Connection, ) { socketClass = connection.socket().javaClass.name } },
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 27K bytes - Viewed (0) -
okhttp-logging-interceptor/src/test/java/okhttp3/logging/LoggingEventListenerTest.kt
.assertLogMatch(Regex("""connectStart: ${url.host}/.+ DIRECT""")) .assertLogMatch(Regex("""connectEnd: http/1.1""")) .assertLogMatch( Regex( """connectionAcquired: Connection\{${url.host}:\d+, proxy=DIRECT hostAddress=${url.host}/.+ cipherSuite=none protocol=http/1\.1\}""", ), ) .assertLogMatch(Regex("""requestHeadersStart"""))
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sun Jan 14 10:20:09 UTC 2024 - 10.2K bytes - Viewed (0)