- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 87 for batch (0.21 sec)
-
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/Certificate.kt
return certificates.single() as X509Certificate } catch (e: NoSuchElementException) { throw IllegalArgumentException("failed to decode certificate", e) } catch (e: IllegalArgumentException) { throw IllegalArgumentException("failed to decode certificate", e) } catch (e: GeneralSecurityException) { throw IllegalArgumentException("failed to decode certificate", e) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.4K bytes - Viewed (0) -
okhttp-java-net-cookiejar/src/main/kotlin/okhttp3/java/net/cookiejar/JavaNetCookieJar.kt
for (cookie in cookies) { cookieStrings.add(cookieToString(cookie, true)) } val multimap = mapOf("Set-Cookie" to cookieStrings) try { cookieHandler.put(url.toUri(), multimap) } catch (e: IOException) { Platform.get().log("Saving cookies failed for " + url.resolve("/...")!!, WARN, e) } } override fun loadForRequest(url: HttpUrl): List<Cookie> { val cookieHeaders = try {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 04:10:43 GMT 2024 - 3.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Dns.kt
val SYSTEM: Dns = DnsSystem() private class DnsSystem : Dns { override fun lookup(hostname: String): List<InetAddress> { try { return InetAddress.getAllByName(hostname).toList() } catch (e: NullPointerException) { throw UnknownHostException("Broken system behaviour for dns lookup of $hostname").apply { initCause(e) } } } } }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.2K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt
try { while (true) { val event = takeEvent() if (eventClass.isInstance(event)) { return eventClass.cast(event) } } } catch (e: NoSuchElementException) { throw AssertionError("full event sequence: $fullEventSequence", e) } } /** * Remove and return the next event from the recorded sequence. *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt
serverSocket!!.reuseAddress = false serverSocket!!.bind(InetSocketAddress("localhost", 0), 1) port = serverSocket!!.localPort executor.execute { try { readAndWriteFrames() } catch (e: IOException) { ******@****.***uietly() logger.info("${this@MockHttp2Peer} done: ${e.message}") } } } private fun readAndWriteFrames() { check(socket == null)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 8.7K bytes - Viewed (0) -
okhttp-android/src/androidTest/kotlin/okhttp3/android/AndroidAsyncDnsTest.kt
var exception: Exception? = null val latch = CountDownLatch(1) // assumes an IPv4 address AndroidAsyncDns.IPv4.query( hostname, object : AsyncDns.Callback { override fun onResponse( hostname: String, addresses: List<InetAddress>, ) { allAddresses.addAll(addresses) latch.countDown() }
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/main/kotlin/okhttp3/internal/platform/Jdk8WithJettyBootPlatform.kt
putMethod.invoke(null, sslSocket, alpnProvider) } catch (e: InvocationTargetException) { throw AssertionError("failed to set ALPN", e) } catch (e: IllegalAccessException) { throw AssertionError("failed to set ALPN", e) } } override fun afterHandshake(sslSocket: SSLSocket) { try { removeMethod.invoke(null, sslSocket) } catch (e: IllegalAccessException) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/platform/android/AndroidSocketAdapter.kt
} // Enable ALPN. setAlpnProtocols.invoke( sslSocket, Platform.concatLengthPrefixed(protocols), ) } catch (e: IllegalAccessException) { throw AssertionError(e) } catch (e: InvocationTargetException) { throw AssertionError(e) } } } override fun getSelectedProtocol(sslSocket: SSLSocket): String? {
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) -
mockwebserver-junit4/src/main/kotlin/mockwebserver3/junit4/MockWebServerRule.kt
val server: MockWebServer = MockWebServer() override fun before() { try { server.start() } catch (e: IOException) { throw RuntimeException(e) } } override fun after() { try { server.shutdown() } catch (e: IOException) { logger.log(Level.WARNING, "MockWebServer shutdown failed", e) } } @ExperimentalOkHttpApi
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 1.8K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/http/CallServerInterceptor.kt
} } } else { exchange.noRequestBody() } if (requestBody == null || !requestBody.isDuplex()) { exchange.finishRequest() } } catch (e: IOException) { if (e is ConnectionShutdownException) { throw e // No request was sent so there's no response to read. } if (!exchange.hasFailure) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.3K bytes - Viewed (1)