- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 109 for dispatcher (0.46 sec)
-
okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt
.connectionPool( buildConnectionPool( connectionListener = connectionListener, taskRunner = taskRunner, ), ) .dispatcher(Dispatcher(backend.executor)) .taskRunnerInternal(taskRunner) } else { OkHttpClient.Builder() .connectionPool(ConnectionPool(connectionListener = connectionListener)) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
// We use a re-entrant dispatcher to initiate one HTTPS connection while the other is in flight. server.dispatcher = object : Dispatcher() { var requestCount = 0 override fun dispatch(request: RecordedRequest): MockResponse { val result = queueDispatcher.dispatch(request) requestCount++ if (requestCount == 1) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 75.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Call.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 3.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/OkHttpClientTest.kt
val a = client.newBuilder().build() 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)
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) -
samples/tlssurvey/src/main/kotlin/okhttp3/survey/ssllabs/SslLabsScrape.kt
} } } suspend fun main() { val client = OkHttpClient() val scraper = SslLabsScraper(client) println(scraper.query()) client.connectionPool.evictAll() client.dispatcher.executorService.shutdown()
Plain Text - Registered: Fri Mar 29 11:42:11 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/TestTls13Request.kt
.build() private fun testClient( urls: List<String>, client: OkHttpClient, ) { try { for (url in urls) { sendRequest(client, url) } } finally { client.dispatcher.executorService.shutdownNow() client.connectionPool.evictAll() } } private fun buildClient(vararg specs: ConnectionSpec): OkHttpClient { return OkHttpClient.Builder() .connectionSpecs(listOf(*specs))
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/session/scope/internal/SessionScope.java
} }; } @SuppressWarnings("unchecked") private <T> T createProxy(Key<T> key, Provider<T> unscoped) { InvocationHandler dispatcher = (proxy, method, args) -> { method.setAccessible(true); try { return method.invoke(getScopeState().scope(key, unscoped).get(), args);
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Tue Apr 23 12:52:20 GMT 2024 - 6.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/DispatcherCleanupTest.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/KotlinDeprecationErrorTest.kt
val headers: Headers? = part.headers() val body: RequestBody = part.body() } @Test @Disabled fun okHttpClient() { val client = OkHttpClient() val dispatcher: Dispatcher = client.dispatcher() val proxy: Proxy? = client.proxy() val protocols: List<Protocol> = client.protocols() val connectionSpecs: List<ConnectionSpec> = client.connectionSpecs()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 13.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/RecordingExecutor.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.1K bytes - Viewed (0)