- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 447 for clone (0.14 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt
windowSizeIncrement = increment, ), ) } 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]. */
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) -
docs/de/docs/reference/websockets.md
- receive_bytes - receive_json - iter_text - iter_bytes - iter_json - send_text - send_bytes - send_json - close Wenn ein Client die Verbindung trennt, wird eine `WebSocketDisconnect`-Exception ausgelöst, die Sie abfangen können. Sie können diese direkt von `fastapi` importieren: ```python
Plain Text - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Sat Mar 30 18:16:27 GMT 2024 - 1.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/InterceptorTest.kt
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/test/java/okhttp3/internal/UtilTest.kt
val socket = Socket() socket.connect(serverSocket.localSocketAddress) val socketSource = socket.source().buffer() assertThat(socket.isHealthy(socketSource)).isTrue() serverSocket.close() assertThat(socket.isHealthy(socketSource)).isFalse() } @Test fun testDurationTimeUnit() { assertThat(checkDuration("timeout", 0, TimeUnit.MILLISECONDS)).isEqualTo(0)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/HeadersRequestTest.kt
@Test fun readNameValueBlockDropsForbiddenHeadersHttp2() { val headerBlock = headersOf( ":status", "200 OK", ":version", "HTTP/1.1", "connection", "close", ) val request = Request.Builder().url("http://square.com/").build() val response = readHttp2HeadersList(headerBlock, Protocol.HTTP_2).request(request).build() val headers = response.headers
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.5K bytes - Viewed (0) -
okhttp-dnsoverhttps/src/test/java/okhttp3/dnsoverhttps/TestDohMain.kt
getOnly = true, ) runBatch(dnsProviders, names) } finally { bootstrapClient.connectionPool.evictAll() bootstrapClient.dispatcher.executorService.shutdownNow() bootstrapClient.cache?.close() }
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-hpacktests/src/test/java/okhttp3/internal/http2/hpackjson/HpackJsonUtil.kt
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/src/main/kotlin/okhttp3/internal/http2/Http2Writer.kt
sink.writeByte(type and 0xff) sink.writeByte(flags and 0xff) sink.writeInt(streamId and 0x7fffffff) } @Throws(IOException::class) override fun close() { this.withLock { closed = true sink.close() } } @Throws(IOException::class) private fun writeContinuationFrames( streamId: Int, byteCount: Long, ) { var byteCount = byteCount
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/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt
private val routeB1 = factory.newRoute(addressB) private val addressC = factory.newAddress("c") private val routeC1 = factory.newRoute(addressC) @AfterEach fun tearDown() { factory.close() peer.close() } @Test fun connectionsEvictedWhenIdleLongEnough() { val pool = factory.newConnectionPool() val c1 = factory.newConnection(pool, routeA1, 50L)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 12.7K bytes - Viewed (0) -
okhttp-android/src/main/baseline-prof.txt
HSPLokio/ForwardingSink;-><init>(Lokio/Sink;)V HSPLokio/ForwardingSink;->close()V HSPLokio/ForwardingSink;->write(Lokio/Buffer;J)V HSPLokio/ForwardingSource;-><init>(Lokio/Source;)V HSPLokio/ForwardingSource;->close()V HSPLokio/GzipSource;-><init>(Lokio/Source;)V HSPLokio/GzipSource;->checkEqual(Ljava/lang/String;II)V HSPLokio/GzipSource;->close()V HSPLokio/GzipSource;->read(Lokio/Buffer;J)J
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Mar 21 11:22:00 GMT 2022 - 127.9K bytes - Viewed (0)