- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for connectionPool (0.07 sec)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ConnectPlan.kt
taskRunner = taskRunner, connectionPool = connectionPool, route = route, rawSocket = rawSocket, javaNetSocket = javaNetSocket!!, handshake = handshake, protocol = protocol!!, socket = socket, pingIntervalMillis = pingIntervalMillis, connectionListener = connectionPool.connectionListener, )
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 18.6K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealCall.kt
val originalRequest: Request, val forWebSocket: Boolean, ) : Call, Cloneable, Lockable { private val connectionPool: RealConnectionPool = client.connectionPool.delegate internal val eventListener: EventListener = client.eventListenerFactory.create(this) private val timeout = object : AsyncTimeout() { override fun timedOut() {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 30 11:30:11 UTC 2025 - 17.8K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/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
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 12.9K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnection.kt
if (allocationLimit < oldLimit) { // We might need new connections to keep policies satisfied connectionPool.scheduleOpener(route.address) } else if (allocationLimit > oldLimit) { // We might no longer need some connections connectionPool.scheduleCloser() } } } override fun handshake(): Handshake? = handshake
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 14.9K bytes - Viewed (0) -
android-test/src/androidTest/java/okhttp/android/test/OkHttpTest.kt
val request = Request.Builder().url(server.url("/")).build() client.newCall(request).execute().use { response -> assertEquals(200, response.code) } client.connectionPool.evictAll() assertEquals(0, client.connectionPool.connectionCount()) client.newCall(request).execute().use { response -> assertEquals(200, response.code) } assertEquals(2, sessionIds.size)
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 02 14:12:28 UTC 2025 - 29K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/publicsuffix/PublicSuffixListGenerator.kt
} suspend fun main() { val publicSuffixListGenerator = PublicSuffixListGenerator() try { publicSuffixListGenerator.import() } finally { publicSuffixListGenerator.client.run { connectionPool.evictAll() dispatcher.executorService.shutdownNow() } }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Aug 06 05:33:11 UTC 2025 - 6.1K bytes - Viewed (0) -
okhttp/api/jvm/okhttp.api
public final fun certificatePinner ()Lokhttp3/CertificatePinner; public final fun connectTimeoutMillis ()I public final fun connectionPool ()Lokhttp3/ConnectionPool; public final fun connectionSpecs ()Ljava/util/List; public final fun cookieJar ()Lokhttp3/CookieJar; public final fun dispatcher ()Lokhttp3/Dispatcher; public final fun dns ()Lokhttp3/Dns;
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 16 09:39:51 UTC 2025 - 69.4K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/CallTest.kt
client = OkHttpClient .Builder() .connectionPool(client.connectionPool) .proxy(server.proxyAddress) .build() executeSynchronously("/a").assertBody("abc") client = OkHttpClient .Builder() .connectionPool(client.connectionPool) .proxy(server.proxyAddress) .build()
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 146.6K bytes - Viewed (0) -
okhttp/api/android/okhttp.api
public final fun certificatePinner ()Lokhttp3/CertificatePinner; public final fun connectTimeoutMillis ()I public final fun connectionPool ()Lokhttp3/ConnectionPool; public final fun connectionSpecs ()Ljava/util/List; public final fun cookieJar ()Lokhttp3/CookieJar; public final fun dispatcher ()Lokhttp3/Dispatcher; public final fun dns ()Lokhttp3/Dns;
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 16 09:39:51 UTC 2025 - 69.4K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt
writer.windowUpdate(0, (windowSize - DEFAULT_INITIAL_WINDOW_SIZE).toLong()) } } // Thread doesn't use client Dispatcher, since it is scoped potentially across clients via // ConnectionPool. taskRunner.newQueue().execute(name = connectionName, block = readerRunnable) } /** Merges [settings] into this peer's settings and sends them to the remote peer. */ @Throws(IOException::class)
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 31.8K bytes - Viewed (0)