- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 62 for Close (0.13 sec)
-
okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt
* * ```java * client.connectionPool().evictAll(); * ``` * * If your client has a cache, call [close()][Cache.close]. Note that it is an error to create calls * against a cache that is closed, and doing so will cause the call to crash. * * ```java * client.cache().close(); * ``` * * OkHttp also uses daemon threads for HTTP/2 connections. These will exit automatically if they * remain idle.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 04:21:33 GMT 2024 - 52K bytes - Viewed (0) -
docs/de/docs/reference/uploadfile.md
members: - file - filename - size - headers - content_type - read - write - seek
Plain Text - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Sat Mar 30 18:17:09 GMT 2024 - 495 bytes - Viewed (0) -
okhttp-logging-interceptor/src/test/java/okhttp3/logging/HttpLoggingInterceptorTest.kt
MockResponse.Builder() .body("Hello!") .setHeader("Content-Type", PLAIN) .build(), ) val response = client.newCall(request().build()).execute() response.body.close() applicationLogs .assertLogEqual("--> GET $url") .assertLogMatch(Regex("""<-- 200 OK $url \(\d+ms, 6-byte body\)""")) .assertNoMoreLogs() networkLogs
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 09:14:38 GMT 2024 - 37.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt
// Write a frame. val length = (end - start).toInt() outputStream.write(outBytes, start.toInt(), length) // If the last frame was truncated, immediately close the connection. if (truncated) { socket.close() } } else { // read a frame val inFrame = InFrame(i, reader) reader.nextFrame(false, inFrame) inFrames.add(inFrame) }
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/src/test/java/okhttp3/FakeRoutePlanner.kt
} override fun sameHostAndPort(url: HttpUrl): Boolean { return url.host == address.url.host && url.port == address.url.port } override fun close() { factory.close() } inner class FakePlan( val id: Int, ) : RoutePlanner.Plan { var planningThrowable: Throwable? = null var canceled = false var connectState = ConnectState.READY
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 6.2K 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/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
internal val writeTimeout = StreamTimeout() /** * The reason why this stream was closed, or null if it closed normally or has not yet been * closed. * * If there are multiple reasons to abnormally close this stream (such as both peers closing it * near-simultaneously) then this is the first reason known to this peer. */ internal var errorCode: ErrorCode? = null get() = this.withLock { field }
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/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
@Timeout(5) @Tag("Slow") class Http2ConnectionTest { private val peer = MockHttp2Peer() private val taskFaker = TaskFaker() @AfterEach fun tearDown() { peer.close() taskFaker.close() } @Test fun serverPingsClientHttp2() { // Write the mocking script. peer.sendFrame().settings(Settings()) peer.acceptFrame() // ACK peer.sendFrame().ping(false, 2, 3)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 75.4K 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)