- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 298 for Closes (0.15 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt
) { check(!closed) { "closed" } checkOffsetAndCount(source.size, 0, byteCount) sink.write(source, byteCount) } override fun flush() { if (closed) return // Don't throw; this stream might have been closed on the caller's behalf. sink.flush() } override fun close() { if (closed) return closed = true detachTimeout(timeout)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 16.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/-UtilCommon.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
} } /** * Closes this connection. This cancels all open streams and unanswered pings. It closes the * underlying input and output streams and shuts down internal task queues. */ override fun close() { close(ErrorCode.NO_ERROR, ErrorCode.CANCEL, null) } internal fun close( connectionCode: ErrorCode, streamCode: ErrorCode,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 32.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache/DiskLruCache.kt
if (civilizedFileSystem) return fileSource lockingSourceCount++ return object : ForwardingSource(fileSource) { private var closed = false override fun close() { super.close() if (!closed) { closed = true synchronized(this@DiskLruCache) { lockingSourceCount-- if (lockingSourceCount == 0 && zombie) {
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) -
okhttp/src/test/java/okhttp3/ConnectionCoalescingTest.kt
* - The first request "wins the race". * - The second request discovers it "lost the race" and closes the connection it just opened. * - The second request uses the coalesced connection from request1. * - The coalesced connection is violently closed after servicing the first request. * - The second request discovers the coalesced connection is unhealthy just after acquiring it. */ @Test
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 18.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
override fun request(): Request = originalRequest /** * Immediately closes the socket connection if it's currently held. Use this to interrupt an * in-flight request from any thread. It's the caller's responsibility to close the request body * and response body streams; otherwise resources may be leaked. *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 17.9K bytes - Viewed (2) -
okhttp/src/main/kotlin/okhttp3/EventListener.kt
* response body is empty this is invoked immediately before returning that to the application. * * If the application closes the response body before attempting a read, this is invoked at the * time it is closed. * * The connection is implicit, and will generally relate to the last [connectionAcquired] event. *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 15.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Cache.kt
init { val source = snapshot.getSource(ENTRY_BODY) bodySource = object : ForwardingSource(source) { @Throws(IOException::class) override fun close() { snapshot.close() super.close() } }.buffer() } override fun contentType(): MediaType? = contentType?.toMediaTypeOrNull()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 26.8K bytes - Viewed (0) -
docs/en/docs/tutorial/request-files.md
* E.g., `await myfile.seek(0)` would go to the start of the file. * This is especially useful if you run `await myfile.read()` once and then need to read the contents again. * `close()`: Closes the file. As all these methods are `async` methods, you need to "await" them. For example, inside of an `async` *path operation function* you can get the contents with: ```Python
Plain Text - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Wed Mar 13 19:02:19 GMT 2024 - 10.2K bytes - Viewed (0) -
docs/changelogs/changelog_2x.md
* Fix: Throw `UnknownServiceException` if a cleartext connection is attempted when explicitly forbidden. * Fix: Throw a `SSLPeerUnverifiedException` when host verification fails. * Fix: MockWebServer explicitly closes sockets. (On some Android releases, closing the input stream and output stream of a socket is not sufficient. * Fix: Buffer outgoing HTTP/2 frames to limit how many outgoing frames are created.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Feb 06 02:19:09 GMT 2022 - 26.6K bytes - Viewed (0)