- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for ConnectionClosed (0.25 sec)
-
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/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt
connection.noNewExchanges = true connectionUser.releaseConnectionNoEvents() } if (toClose != null) { toClose.closeQuietly() connectionListener.connectionClosed(connection) } else if (noNewExchangesEvent) { connectionListener.noNewExchanges(connection) } } return null } fun put(connection: RealConnection) {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 16.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/ConnectionListener.kt
*/ open fun connectEnd( connection: Connection, route: Route, call: Call, ) {} /** * 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, ) {} /**
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-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt
connection: Connection, route: Route, call: Call, ) { logEvent(ConnectionEvent.ConnectEnd(System.nanoTime(), connection, route, call)) } override fun connectionClosed(connection: Connection) = logEvent(ConnectionEvent.ConnectionClosed(System.nanoTime(), connection)) override fun connectionAcquired( connection: Connection, call: Call, ) {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 5.6K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/ConnectionEvent.kt
val route: Route, val call: Call, ) : ConnectionEvent() { override fun closes(event: ConnectionEvent): Boolean = event is ConnectStart && call == event.call && route == event.route } data class ConnectionClosed( override val timestampNs: Long, override val connection: Connection, ) : ConnectionEvent() data class ConnectionAcquired( override val timestampNs: Long, override val connection: Connection,
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/CallConnectionUser.kt
connection.connectionListener.connectionReleased(connection, call) } override fun connectionConnectionClosed(connection: RealConnection) { connection.connectionListener.connectionClosed(connection) } override fun noNewExchanges(connection: RealConnection) { connection.connectionListener.noNewExchanges(connection) } override fun doExtensiveHealthChecks(): Boolean {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Wed Mar 06 17:33:38 UTC 2024 - 3.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ConnectionListenerTest.kt
} assertThat(listener.recordedEventTypes()).containsExactly( "ConnectStart", "ConnectEnd", "ConnectionAcquired", "NoNewExchanges", "ConnectionReleased", "ConnectionClosed", ) } @Throws(IOException::class) private fun assertSuccessfulEventOrder() { val call = client.newCall( Request.Builder() .url(server!!.url("/"))
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/internal/connection/RealCall.kt
eventListener.connectionReleased(this, connection) connection.connectionListener.connectionReleased(connection, this) if (toClose != null) { connection.connectionListener.connectionClosed(connection) } } else { check(toClose == null) // If we still have a connection we shouldn't be closing any sockets. } } val result = timeoutExit(e)
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 17.9K bytes - Viewed (0) -
okhttp/api/okhttp.api
public fun connectFailed (Lokhttp3/Route;Lokhttp3/Call;Ljava/io/IOException;)V public fun connectStart (Lokhttp3/Route;Lokhttp3/Call;)V public fun connectionAcquired (Lokhttp3/Connection;Lokhttp3/Call;)V public fun connectionClosed (Lokhttp3/Connection;)V public fun connectionReleased (Lokhttp3/Connection;Lokhttp3/Call;)V public fun noNewExchanges (Lokhttp3/Connection;)V } public final class okhttp3/ConnectionListener$Companion {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Apr 15 13:41:01 UTC 2024 - 70.2K bytes - Viewed (0)