- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 48 for handlers (0.14 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/platform/BouncyCastlePlatform.kt
} } override fun getSelectedProtocol(sslSocket: SSLSocket): String? = if (sslSocket is BCSSLSocket) { when (val protocol = (sslSocket as BCSSLSocket).applicationProtocol) { // Handles both un-configured and none selected. null, "" -> null else -> protocol } } else { super.getSelectedProtocol(sslSocket) } companion object {
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) -
android-test/src/androidTest/java/okhttp/android/test/OkHttpTest.kt
import java.security.Security import java.security.cert.Certificate import java.security.cert.CertificateException import java.security.cert.X509Certificate import java.util.concurrent.atomic.AtomicInteger import java.util.logging.Handler import java.util.logging.Level import java.util.logging.LogRecord import java.util.logging.Logger import javax.net.ssl.HostnameVerifier import javax.net.ssl.SSLPeerUnverifiedException import javax.net.ssl.SSLSocket
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 27K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt
when (type) { TYPE_DATA -> readData(handler, length, flags, streamId) TYPE_HEADERS -> readHeaders(handler, length, flags, streamId) TYPE_PRIORITY -> readPriority(handler, length, flags, streamId) TYPE_RST_STREAM -> readRstStream(handler, length, flags, streamId) TYPE_SETTINGS -> readSettings(handler, length, flags, streamId) TYPE_PUSH_PROMISE -> readPushPromise(handler, length, flags, streamId)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 19.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/platform/OpenJSSEPlatform.kt
} } override fun getSelectedProtocol(sslSocket: SSLSocket): String? = if (sslSocket is org.openjsse.javax.net.ssl.SSLSocket) { when (val protocol = sslSocket.applicationProtocol) { // Handles both un-configured and none selected. null, "" -> null else -> protocol } } else { super.getSelectedProtocol(sslSocket) } companion object {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/InterceptorTest.kt
interceptorThrowsRuntimeExceptionAsynchronous(true) } /** * When an interceptor throws an unexpected exception, asynchronous calls are canceled. The * exception goes to the uncaught exception handler. */ private fun interceptorThrowsRuntimeExceptionAsynchronous(network: Boolean) { val boom = RuntimeException("boom!") addInterceptor(network) { chain: Interceptor.Chain? -> throw boom }
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/src/main/kotlin/okhttp3/internal/http/CallServerInterceptor.kt
): Boolean = when { // Server sent a 100-continue even though we did not request one. Try again to read the // actual response status. code == 100 -> true // Handle Processing (102) & Early Hints (103) and any new codes without failing // 100 and 101 are the exceptions with different meanings // But Early Hints not currently exposed code in (102 until 200) -> true
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) -
okhttp/src/main/kotlin/okhttp3/internal/platform/Jdk8WithJettyBootPlatform.kt
throw AssertionError("failed to get ALPN selected protocol", e) } catch (e: IllegalAccessException) { throw AssertionError("failed to get ALPN selected protocol", e) } } /** * Handle the methods of ALPN's ClientProvider and ServerProvider without a compile-time * dependency on those interfaces. */ private class AlpnProvider( /** This peer's supported protocols. */
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/concurrent/TaskRunner.kt
* until one is ready. If there are no ready queues, or if other threads have everything under * control this will return null. If there is more than a single task ready to execute immediately * this will start another thread to handle that work. */ fun awaitTaskToRun(): Task? { lock.assertHeld() while (true) { if (readyQueues.isEmpty()) { return null // Nothing to do. }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 10.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/ResponseBody.kt
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 (0) -
mockwebserver/api/mockwebserver3.api
public abstract fun getRequestBody ()Lokio/BufferedSource; public abstract fun getResponseBody ()Lokio/BufferedSink; } public abstract interface class mockwebserver3/StreamHandler { public abstract fun handle (Lmockwebserver3/Stream;)V
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 03 21:59:45 GMT 2023 - 12.7K bytes - Viewed (0)