- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 481 for Clauss (0.59 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/platform/android/AndroidSocketAdapter.kt
/** * Builds a SocketAdapter from an observed implementation class, by grabbing the Class * reference to perform reflection on at runtime. * * @param actualSSLSocketClass the runtime class of Conscrypt class socket. */ private fun build(actualSSLSocketClass: Class<in SSLSocket>): AndroidSocketAdapter { var possibleClass: Class<in SSLSocket>? = actualSSLSocketClass
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) -
okhttp/src/main/kotlin/okhttp3/internal/platform/Jdk8WithJettyBootPlatform.kt
val alpnClass = Class.forName(alpnClassName, true, null) val providerClass = Class.forName("$alpnClassName\$Provider", true, null) val clientProviderClass = Class.forName("$alpnClassName\$ClientProvider", true, null) val serverProviderClass = Class.forName("$alpnClassName\$ServerProvider", true, null) val putMethod = alpnClass.getMethod("put", SSLSocket::class.java, providerClass)
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) -
mockwebserver/api/mockwebserver3.api
} public final class mockwebserver3/MockResponse$Companion { } public abstract interface class mockwebserver3/MockResponseBody { public abstract fun getContentLength ()J public abstract fun writeTo (Lokio/BufferedSink;)V } public final class mockwebserver3/MockWebServer : java/io/Closeable {
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) -
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/Adapters.kt
ByteString::class to OCTET_STRING, Unit::class to NULL, Nothing::class to OBJECT_IDENTIFIER, Nothing::class to UTF8_STRING, String::class to PRINTABLE_STRING, Nothing::class to IA5_STRING, Nothing::class to UTC_TIME, Long::class to GENERALIZED_TIME, AnyValue::class to ANY_VALUE, ) fun any(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 15K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt
} } @Test @Throws(Exception::class) fun compressedMessages() { successfulExtensions("permessage-deflate") } @Test @Throws(Exception::class) fun compressedMessagesNoClientContextTakeover() { successfulExtensions("permessage-deflate; client_no_context_takeover") } @Test @Throws(Exception::class) fun compressedMessagesNoServerContextTakeover() {
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/main/kotlin/okhttp3/internal/http2/Http2Writer.kt
if (byteCount > length) writeContinuationFrames(streamId, byteCount - length) } } @Throws(IOException::class) fun flush() { this.withLock { if (closed) throw IOException("closed") sink.flush() } } @Throws(IOException::class) fun rstStream( streamId: Int, errorCode: ErrorCode, ) { this.withLock {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 11.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt
} handler.windowUpdate(streamId, increment) } @Throws(IOException::class) override fun close() { source.close() } /** * Decompression of the header block occurs above the framing layer. This class lazily reads * continuation frames as they are needed by [Hpack.Reader.readHeaders]. */ internal class ContinuationSource( private val source: BufferedSource, ) : Source {
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/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
import org.junit.jupiter.params.ParameterizedTest import org.junit.jupiter.params.provider.ArgumentsSource /** Test how HTTP/2 interacts with HTTP features. */ @Timeout(60) @Flaky @Tag("Slow") class HttpOverHttp2Test { class ProtocolParamProvider : SimpleProvider() { override fun arguments() = listOf(Protocol.H2_PRIOR_KNOWLEDGE, Protocol.HTTP_2) } @RegisterExtension val platform: PlatformRule = PlatformRule()
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/internal/ws/RealWebSocketTest.kt
client.listener.assertFailure(IOException::class.java, "source is closed") assertThat(client.webSocket!!.send("Hello!")).isFalse() } @Test fun socketClosedDuringMessageKillsWebSocket() { client2Server.source.close() assertThat(client.webSocket!!.send("Hello!")).isTrue() taskFaker.runTasks() client.listener.assertFailure(IOException::class.java, "source is closed")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 01:59:58 GMT 2024 - 18.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/io/FaultyFileSystem.kt
} else { renameFaults.remove(file) } } @Throws(IOException::class) override fun atomicMove( source: Path, target: Path, ) { if (renameFaults.contains(source) || renameFaults.contains(target)) throw IOException("boom!") super.atomicMove(source, target) } @Throws(IOException::class) override fun delete( path: Path, mustExist: Boolean, ) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.8K bytes - Viewed (0)