- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 21 for connectionPool (0.19 sec)
-
okhttp/src/main/kotlin/okhttp3/ConnectionPool.kt
* application. The tuning parameters in this pool are subject to change in future OkHttp releases. * Currently this pool holds up to 5 idle connections which will be evicted after 5 minutes of * inactivity. */ class ConnectionPool internal constructor( internal val delegate: RealConnectionPool, ) { internal constructor( maxIdleConnections: Int = 5, keepAliveDuration: Long = 5, timeUnit: TimeUnit = TimeUnit.MINUTES,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 03 20:39:41 GMT 2024 - 5.6K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/TestValueFactory.kt
): RealRoutePlanner { val call = RealCall(client, Request(address.url), forWebSocket = false) val chain = newChain(call) return RealRoutePlanner( taskRunner = client.taskRunner, connectionPool = client.connectionPool.delegate, readTimeoutMillis = client.readTimeoutMillis, writeTimeoutMillis = client.writeTimeoutMillis, socketConnectTimeoutMillis = chain.connectTimeoutMillis,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 7.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectPlan.kt
taskRunner = taskRunner, connectionPool = connectionPool, route = route, rawSocket = rawSocket, socket = socket, handshake = handshake, protocol = protocol, source = source, sink = sink, pingIntervalMillis = pingIntervalMillis, connectionListener = connectionPool.connectionListener, )
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/ConnectionPoolTest.kt
} @Test fun inUseConnectionsNotEvicted() { val pool = factory.newConnectionPool() val poolApi = ConnectionPool(pool) val c1 = factory.newConnection(pool, routeA1, 50L) val client = OkHttpClient.Builder() .connectionPool(poolApi) .build() val call = client.newCall(Request(addressA.url)) as RealCall
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 12.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt
val queue: TaskQueue, var policy: ConnectionPool.AddressPolicy, ) { /** * How many calls the pool can carry without opening new connections. This field must only be * accessed by the connection closer task. */ var concurrentCallCapacity: Int = 0 } companion object { fun get(connectionPool: ConnectionPool): RealConnectionPool = connectionPool.delegate
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 16.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
val originalRequest: Request, val forWebSocket: Boolean, ) : Call, Cloneable { internal val lock: ReentrantLock = ReentrantLock() private val connectionPool: RealConnectionPool = client.connectionPool.delegate internal val eventListener: EventListener = client.eventListenerFactory.create(this) private val timeout = object : AsyncTimeout() { override fun timedOut() {
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/RealConnection.kt
fun newTestConnection( taskRunner: TaskRunner, connectionPool: RealConnectionPool, route: Route, socket: Socket, idleAtNs: Long, ): RealConnection { val result = RealConnection( taskRunner = taskRunner, connectionPool = connectionPool, route = route, rawSocket = null, socket = socket,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 15.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt
internal val taskRunner: TaskRunner = builder.taskRunner ?: TaskRunner.INSTANCE @get:JvmName("connectionPool") val connectionPool: ConnectionPool = builder.connectionPool ?: ConnectionPool( readTimeoutMillis = readTimeoutMillis, writeTimeoutMillis = writeTimeoutMillis, socketConnectTimeoutMillis = connectTimeoutMillis,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 04:21:33 GMT 2024 - 52K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/OkHttpClientTest.kt
assertThat(a.dispatcher).isNotNull() assertThat(a.connectionPool).isNotNull() assertThat(a.sslSocketFactory).isNotNull() assertThat(a.x509TrustManager).isNotNull() // Multiple clients share the instances. val b = client.newBuilder().build() assertThat(b.dispatcher).isSameAs(a.dispatcher) assertThat(b.connectionPool).isSameAs(a.connectionPool) assertThat(b.sslSocketFactory).isSameAs(a.sslSocketFactory)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 13.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/KotlinSourceModernTest.kt
} } @Test fun connectionPool() { var connectionPool = ConnectionPool() connectionPool = ConnectionPool(0, 0L, TimeUnit.SECONDS) val idleConnectionCount: Int = connectionPool.idleConnectionCount() val connectionCount: Int = connectionPool.connectionCount() connectionPool.evictAll() } @Test fun connectionSpec() {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 01 14:21:25 GMT 2024 - 46.5K bytes - Viewed (4)