- Sort Score
- Result 10 results
- Languages All
Results 11 - 17 of 17 for ConnectionListener (0.25 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
} if (this.connection == null) { toClose?.closeQuietly() 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.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 17.9K bytes - Viewed (2) -
okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectPlan.kt
handshake = handshake, protocol = protocol, source = source, sink = sink, pingIntervalMillis = pingIntervalMillis, connectionListener = connectionPool.connectionListener, ) this.connection = connection connection.start() // Success. user.callConnectEnd(route, protocol) success = true
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 18.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/RouteSelectorTest.kt
import java.net.Proxy import java.net.ProxySelector import java.net.SocketAddress import java.net.URI import java.net.UnknownHostException import kotlin.test.assertFailsWith import okhttp3.Address import okhttp3.ConnectionListener import okhttp3.FakeDns import okhttp3.OkHttpClientTestRule import okhttp3.Request import okhttp3.Route import okhttp3.TestValueFactory import okhttp3.internal.connection.RouteSelector.Companion.socketHost
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Mar 06 17:33:38 GMT 2024 - 20.8K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.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, ) : ConnectionListener() { val eventSequence: Deque<ConnectionEvent> = ConcurrentLinkedDeque() private val forbiddenLocks = mutableSetOf<Any>() /** The timestamp of the last taken event, used to measure elapsed time between events. */
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ConnectionListenerTest.kt
private val handshakeCertificates = localhost() open val fastFallback: Boolean get() = true private var client: OkHttpClient = clientTestRule.newClientBuilder() .connectionPool(ConnectionPool(connectionListener = listener)) .fastFallback(fastFallback) .build() @BeforeEach fun setUp(server: MockWebServer?) { this.server = server platform.assumeNotOpenJSSE()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 9.6K bytes - Viewed (0) -
okhttp/api/okhttp.api
} public final class okhttp3/ConnectionListener$Companion { public final fun getNONE ()Lokhttp3/ConnectionListener; } public final class okhttp3/ConnectionPool { public fun <init> ()V public fun <init> (IJLjava/util/concurrent/TimeUnit;)V public fun <init> (IJLjava/util/concurrent/TimeUnit;Lokhttp3/ConnectionListener;)V
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 13:41:01 GMT 2024 - 70.2K bytes - Viewed (0) -
CHANGELOG.md
different cipher suite than before! OkHttp's defaults cipher suites are selected for good security and performance. * New: `ConnectionListener` publishes events for connects, disconnects, and use of pooled connections. * Fix: Immediately update the connection's flow control window instead of waiting for the receiving stream to process it.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 18 01:31:39 GMT 2024 - 21.4K bytes - Viewed (0)