- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 56 for amatch (0.28 sec)
-
mockwebserver-junit4/src/test/java/mockwebserver3/junit4/MockWebServerRuleTest.kt
}, Description.EMPTY, ) statement.evaluate() assertThat(called.get()).isTrue() try { rule.server.url("/").toUrl().openConnection().connect() fail() } catch (expected: ConnectException) { } }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.5K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/connection/SequentialExchangeFinder.kt
if (nextPlan != null) { routePlanner.deferredPlans.addFirst(nextPlan) continue } } return plan.handleSuccess() } catch (e: IOException) { if (firstException == null) { firstException = e } else { firstException.addSuppressed(e) } if (!routePlanner.hasNext()) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/tls/BasicTrustRootIndex.kt
val subjectCaCerts = subjectToCaCerts[issuer] ?: return null return subjectCaCerts.firstOrNull { try { cert.verify(it.publicKey) return@firstOrNull true } catch (_: Exception) { return@firstOrNull false } } } override fun equals(other: Any?): Boolean { return other === this ||
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.8K bytes - Viewed (0) -
okhttp-android/src/main/kotlin/okhttp3/android/AndroidAsyncDns.kt
callback.onFailure( hostname, UnknownHostException(e.message).apply { initCause(e) }, ) } }, ) } catch (e: Exception) { // Handle any errors that might leak out // https://issuetracker.google.com/issues/319957694 callback.onFailure( hostname, UnknownHostException(e.message).apply {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 01 10:07:48 GMT 2024 - 2.8K bytes - Viewed (0) -
mockwebserver/src/test/java/mockwebserver3/CustomDispatcherTest.kt
val secondResponseCode = AtomicInteger() val secondRequest = "/bar" val firstRequest = "/foo" val latch = CountDownLatch(1) val dispatcher: Dispatcher = object : Dispatcher() { override fun dispatch(request: RecordedRequest): MockResponse { if (request.path == firstRequest) { latch.await() } return MockResponse() } }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.3K bytes - Viewed (0) -
okhttp-sse/src/main/kotlin/okhttp3/sse/internal/RealEventSource.kt
try { if (!canceled) { listener.onOpen(this, response) while (!canceled && reader.processNextEvent()) { } } } catch (e: Exception) { val exception = when { canceled -> IOException("canceled", e) else -> e } listener.onFailure(this, exception, response) return
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/WebPlatformToAsciiTest.kt
val failures = mutableListOf<Throwable>() for (entry in list) { var failure: Throwable? = null try { testToAscii(entry.input!!, entry.output, entry.comment) } catch (e: Throwable) { failure = e } if (entry.input in knownFailures) { if (failure == null) failures += AssertionError("known failure didn't fail: $entry") } else {
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) -
samples/guide/src/main/java/okhttp3/recipes/PostStreamingWithPipe.java
Java - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Fri Jul 06 03:18:15 GMT 2018 - 3.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/-MediaTypeCommon.kt
} /** Returns a media type for this, or null if this is not a well-formed media type. */ fun String.commonToMediaTypeOrNull(): MediaType? { return try { commonToMediaType() } catch (_: IllegalArgumentException) { null }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http/ThreadInterruptTest.kt
while (responseBody.read(buffer) != -1) { } } responseBody.close() } private fun sleep(delayMillis: Int) { try { Thread.sleep(delayMillis.toLong()) } catch (e: InterruptedException) { Thread.currentThread().interrupt() } } private fun interruptLater(delayMillis: Int) { val toInterrupt = Thread.currentThread() val interruptingCow =
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)