- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 109 for dispatcher (0.21 sec)
-
okhttp-dnsoverhttps/src/test/java/okhttp3/dnsoverhttps/TestDohMain.kt
http2Only = true, workingOnly = true, getOnly = true, ) runBatch(dnsProviders, names) } finally { bootstrapClient.connectionPool.evictAll() bootstrapClient.dispatcher.executorService.shutdownNow() bootstrapClient.cache?.close() }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/AutobahnTester.kt
try { val count = getTestCount() println("Test count: $count") for (number in 1..count) { runTest(number, count) } updateReports() } finally { client.dispatcher.executorService.shutdown() } } private fun runTest( number: Long, count: Long, ) { val latch = CountDownLatch(1) val startNanos = AtomicLong() newWebSocket(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.6K bytes - Viewed (0) -
okcurl/src/main/kotlin/okhttp3/curl/Main.kt
} return builder.build() } fun close() { val okHttpClient = client as OkHttpClient okHttpClient.connectionPool.evictAll() // Close any persistent connections. okHttpClient.dispatcher.executorService.shutdownNow() } companion object { internal const val NAME = "okcurl" internal const val DEFAULT_TIMEOUT = -1 private fun versionString(): String? {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.7K bytes - Viewed (1) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt
* byte of a frame but no more frames. */ @Test fun readTimeoutAppliesWithinFrames() { webServer.dispatcher = object : Dispatcher() { override fun dispatch(request: RecordedRequest): MockResponse { return upgradeResponse(request) .body(Buffer().write("81".decodeHex())) // Truncated frame.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 35.2K bytes - Viewed (1) -
mockwebserver/src/test/java/mockwebserver3/MockWebServerTest.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 23.5K bytes - Viewed (0) -
okhttp/api/okhttp.api
public final fun -deprecated_connectionSpecs ()Ljava/util/List; public final fun -deprecated_cookieJar ()Lokhttp3/CookieJar; public final fun -deprecated_dispatcher ()Lokhttp3/Dispatcher; public final fun -deprecated_dns ()Lokhttp3/Dns; public final fun -deprecated_eventListenerFactory ()Lokhttp3/EventListener$Factory; public final fun -deprecated_followRedirects ()Z
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) -
okhttp/src/test/java/okhttp3/ConnectionListenerTest.kt
fun setUp(server: MockWebServer?) { this.server = server platform.assumeNotOpenJSSE() platform.assumeNotBouncyCastle() listener.forbidLock(get(client.connectionPool)) listener.forbidLock(client.dispatcher) } @ParameterizedTest @ValueSource(booleans = [true, false]) fun successfulCallEventSequence() { server!!.enqueue(MockResponse(body = "abc")) val call = client.newCall(
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/src/test/java/okhttp3/InterceptorTest.kt
val boom = RuntimeException("boom!") addInterceptor(network) { chain: Interceptor.Chain? -> throw boom } val executor = ExceptionCatchingExecutor() client = client.newBuilder() .dispatcher(Dispatcher(executor)) .build() val request = Request.Builder() .url(server.url("/")) .build() val call = client.newCall(request) call.enqueue(callback)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Jan 14 10:20:09 GMT 2024 - 27.8K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/kt/WiresharkExample.kt
sendTestRequest(twitterRequest) Thread.sleep(1000) sendTestRequest(googleRequest) Thread.sleep(2000) } } finally { client.connectionPool.evictAll() client.dispatcher.executorService.shutdownNow() if (launch == CommandLine) { process?.destroyForcibly() } } } private fun sendTestRequest(request: Request) { try {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.7K bytes - Viewed (1) -
mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/MockWebServerTest.kt
val connection = server.url("/").toUrl().openConnection() as HttpURLConnection connection.setReadTimeout(500) try { connection.getResponseCode() fail<Any>() } catch (expected: SocketTimeoutException) { } // Shutting down the server should unblock the dispatcher. server.shutdown() } @Test
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 21.9K bytes - Viewed (0)