- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 27 for Hawaii (0.15 sec)
-
okhttp/src/test/java/okhttp3/DispatcherTest.kt
try { proceed.await(5, TimeUnit.SECONDS) } catch (e: InterruptedException) { throw RuntimeException(e) } chain.proceed(chain.request()) }, ) .build() val t1 = makeSynchronousCall(client.newCall(newRequest("http://a/3"))) ready.await(5, TimeUnit.SECONDS) executor.finishJob("http://a/2")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Fri Apr 05 03:30:42 GMT 2024 - 12.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerRealBackendTest.kt
throw RuntimeException("boom!") } queue.schedule("task", TimeUnit.MILLISECONDS.toNanos(200)) { log.put("normal task running") return@schedule -1L } queue.idleLatch().await(500, TimeUnit.MILLISECONDS) assertThat(log.take()).isEqualTo("failing task running") assertThat(log.take()).isEqualTo("uncaught exception: java.lang.RuntimeException: boom!")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/WholeOperationTimeoutTest.kt
override fun onResponse( call: Call, response: Response, ) { response.close() latch.countDown() } }, ) latch.await() assertThat(call.isCanceled()).isTrue() assertThat(exceptionRef.get()).isNotNull() } @Test fun timeoutProcessing() { server.enqueue( MockResponse.Builder()
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/InterceptorTest.kt
.build() } val request = Request.Builder() .url(server.url("/")) .build() client.newCall(request).enqueue(callback) callback.await(request.url) .assertCode(200) .assertHeader("OkHttp-Intercepted", "yep") } @Test fun applicationInterceptorsCanMakeMultipleRequestsToServer() {
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) -
okhttp-android/src/androidTest/kotlin/okhttp3/android/AndroidAsyncDnsTest.kt
override fun onFailure( hostname: String, e: IOException, ) { exception = e latch.countDown() } }, ) latch.await() return Pair(allAddresses, exception) } @Test fun testDnsRequestExternal() { assumeNetwork() val (allAddresses, exception) = dnsQuery("google.com")
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 (0) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
fail("") } }, ) assertThat(server.takeRequest().sequenceNumber) .isEqualTo(expectedSequenceNumber) responseDequeuedLatch!!.await() call.cancel() requestCanceledLatch!!.countDown() latch.await() } @ParameterizedTest @ArgumentsSource(ProtocolParamProvider::class) fun noRecoveryFromRefusedStreamWithRetryDisabled( protocol: Protocol,
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/test/java/okhttp3/FastFallbackTest.kt
var first = true override fun createSocket(): Socket { if (first) { first = false firstConnectLatch.await() } return super.createSocket() } } client = client.newBuilder() .protocols(listOf(Protocol.H2_PRIOR_KNOWLEDGE))
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.3K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
} val startedTask = startNextTask() val otherTasksStarted = startedTask != yieldCompleteTask try { while (currentTask != self) { taskRunner.condition.await() } } finally { serialTaskQueue.remove(yieldCompleteTask) } // If we're yielding until we're exhausted and a task run, keep going until a task doesn't run.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 12.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt
object : WebSocketListener() { override fun onOpen( webSocket: WebSocket, response: Response, ) { try { latch.await() // The server can't respond to pings! } catch (e: InterruptedException) { throw AssertionError(e) } } }, ) .build(), )
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) -
okhttp/src/test/java/okhttp3/CallTest.kt
callback.await(server.url("/a")).assertBody("abc") client.newCall(Request.Builder().url(server.url("/b")).build()).enqueue(callback) callback.await(server.url("/b")).assertBody("def") client.newCall(Request.Builder().url(server.url("/c")).build()).enqueue(callback) callback.await(server.url("/c")).assertBody("ghi")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 142.5K bytes - Viewed (0)