- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 104 for Clauss (0.17 sec)
-
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
receivedByteCount += byteCount } @Throws(IOException::class) override fun flush() { } override fun timeout(): Timeout = Timeout.NONE @Throws(IOException::class) override fun close() { } } /** Processes HTTP requests layered over HTTP/2. */ private inner class Http2SocketHandler constructor( private val socket: Socket,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 37.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketReader.kt
* corresponding call to [FrameCallback]. */ @Throws(IOException::class) fun processNextFrame() { readHeader() if (isControlFrame) { readControlFrame() } else { readMessageFrame() } } @Throws(IOException::class, ProtocolException::class) private fun readHeader() { if (closed) throw IOException("closed")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
/** * A source that reads the incoming data frames of a stream. Although this class uses * synchronization to safely receive incoming data frames, it is not intended for use by multiple * readers. */ inner class FramingSource internal constructor( /** Maximum number of bytes to buffer before reporting a flow control error. */ private val maxByteCount: Long,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 23.2K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/cache/DiskLruCache.kt
} @Throws(FileNotFoundException::class) private fun newJournalWriter(): BufferedSink { val fileSink = fileSystem.appendingSink(journalFile) val faultHidingSink = FaultHidingSink(fileSink) { ******@****.***ThreadHoldsLock() hasJournalErrors = true } return faultHidingSink.buffer() } @Throws(IOException::class) private fun readJournalLine(line: String) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 34.7K bytes - Viewed (0) -
mockwebserver-deprecated/api/mockwebserver.api
public abstract class okhttp3/mockwebserver/Dispatcher { public fun <init> ()V public abstract fun dispatch (Lokhttp3/mockwebserver/RecordedRequest;)Lokhttp3/mockwebserver/MockResponse; public fun peek ()Lokhttp3/mockwebserver/MockResponse; public fun shutdown ()V } public final class okhttp3/mockwebserver/MockResponse : java/lang/Cloneable { public static final field Companion Lokhttp3/mockwebserver/MockResponse$Companion;
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jul 22 12:28:51 GMT 2023 - 10.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/OkHttpClientTest.kt
assertThat(client.proxySelector) .isNotInstanceOf(NullProxySelector::class.java) client = OkHttpClient.Builder() .proxy(Proxy.NO_PROXY) .build() assertThat(client.proxy).isSameAs(Proxy.NO_PROXY) assertThat(client.proxySelector) .isInstanceOf(NullProxySelector::class.java) client = OkHttpClient.Builder() .proxySelector(FakeProxySelector())
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 13.2K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/kt/WiresharkExample.kt
* 3. Register with `client.eventListenerFactory(eventListenerFactory)` * 4. Launch wireshark if not done externally `val process = eventListenerFactory.launchWireShark()` */ @SuppressSignatureCheck class WireSharkListenerFactory( private val logFile: File, private val tlsVersions: List<TlsVersion>, private val launch: Launch? = null, ) : EventListener.Factory { override fun create(call: Call): EventListener {
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 (1) -
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerReader.kt
* * BER: Basic Encoding Rules. * * This class was implemented according to the [X.690 spec][[x690]], and under the advice of * [Lets Encrypt's ASN.1 and DER][asn1_and_der] guide. * * [x690]: https://www.itu.int/rec/T-REC-X.690 * [asn1_and_der]: https://letsencrypt.org/docs/a-warm-welcome-to-asn1-and-der/ */ internal class DerReader(source: Source) {
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/main/kotlin/okhttp3/internal/publicsuffix/PublicSuffixDatabase.kt
import okio.Path import okio.Path.Companion.toPath import okio.buffer /** * A database of public suffixes provided by [publicsuffix.org][publicsuffix_org]. * * [publicsuffix_org]: https://publicsuffix.org/ */ class PublicSuffixDatabase internal constructor( val path: Path = PUBLIC_SUFFIX_RESOURCE, val fileSystem: FileSystem = FileSystem.RESOURCES, ) { /** True after we've attempted to read the list for the first time. */
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/UrlComponentEncodingTester.kt
import okio.ByteString import okio.ByteString.Companion.encodeUtf8 /** * Tests how each code point is encoded and decoded in the context of each URL component. * * This supports [HttpUrlTest]. */ class UrlComponentEncodingTester private constructor() { private val encodings: MutableMap<Int, Encoding> = LinkedHashMap() private fun allAscii(encoding: Encoding) = apply { for (i in 0..127) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 12.3K bytes - Viewed (0)