- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 24 for iostream (0.21 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/http2/StreamResetException.kt
* limitations under the License. */ package okhttp3.internal.http2 import java.io.IOException /** Thrown when an HTTP/2 stream is canceled without damage to the socket that carries it. */ class StreamResetException( @JvmField val errorCode: ErrorCode,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 869 bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/cache2/RelayTest.kt
fun setUp() { file = File(tempDir, "test") } @AfterEach fun tearDown() { executor.shutdown() } @Test fun singleSource() { val upstream = Buffer() upstream.writeUtf8("abcdefghijklm") val relay = edit(file, upstream, metadata, 1024) val source = relay.newSource() val sourceBuffer = Buffer() assertThat(source!!.read(sourceBuffer, 5)).isEqualTo(5)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 8.1K bytes - Viewed (0) -
docs/contribute/debug_logging.md
[2020-01-01 00:00:00] >> 0x00000000 6 SETTINGS [2020-01-01 00:00:00] >> 0x00000000 4 WINDOW_UPDATE [2020-01-01 00:00:00] >> 0x00000003 47 HEADERS END_STREAM|END_HEADERS [2020-01-01 00:00:00] << 0x00000000 6 SETTINGS [2020-01-01 00:00:00] << 0x00000000 0 SETTINGS ACK [2020-01-01 00:00:00] << 0x00000000 4 WINDOW_UPDATE
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Feb 06 16:35:36 GMT 2022 - 2.7K bytes - Viewed (0) -
mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/SocketPolicy.kt
DISCONNECT_DURING_REQUEST_BODY, DISCONNECT_DURING_RESPONSE_BODY, DO_NOT_READ_REQUEST_BODY, FAIL_HANDSHAKE, SHUTDOWN_INPUT_AT_END, SHUTDOWN_OUTPUT_AT_END, STALL_SOCKET_AT_START, NO_RESPONSE, RESET_STREAM_AT_START, EXPECT_CONTINUE, CONTINUE_ALWAYS,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/MultipartReader.kt
import okio.Buffer import okio.BufferedSource import okio.ByteString.Companion.encodeUtf8 import okio.Options import okio.Source import okio.Timeout import okio.buffer /** * Reads a stream of [RFC 2046][rfc_2046] multipart body parts. Callers read parts one-at-a-time * until [nextPart] returns null. After calling [nextPart] any preceding parts should not be read. * * Typical use loops over the parts in sequence:
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 7.1K bytes - Viewed (0) -
docs/changelogs/changelog_1x.md
currently-shipping versions. * Support asynchronous disconnects by breaking the socket only. This should prevent flakiness from multiple threads concurrently accessing a stream. ## Version 1.5.3 _2014-03-29_ * Fix bug where the Content-Length header was not always dropped when following a redirect from a POST to a GET.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Feb 06 02:19:09 GMT 2022 - 6.4K bytes - Viewed (0) -
docs/contribute/code_of_conduct.md
* **Be collaborative**: Collaboration reduces redundancy and improves the quality of our work. We strive for transparency within our open source community, and we work closely with upstream developers and others in the free software community to coordinate our efforts. * **Be pragmatic**: Questions are encouraged and should be asked early in the process to avoid
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Feb 06 02:19:09 GMT 2022 - 5.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Call.kt
package okhttp3 import okio.IOException import okio.Timeout /** * A call is a request that has been prepared for execution. A call can be canceled. As this object * represents a single request/response pair (stream), it cannot be executed twice. */ interface Call : Cloneable { /** Returns the original request that initiated this call. */ fun request(): Request /**
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 3.6K bytes - Viewed (0) -
docs/features/calls.md
## [Requests](https://square.github.io/okhttp/4.x/okhttp/okhttp3/-request/) Each HTTP request contains a URL, a method (like `GET` or `POST`), and a list of headers. Requests may also contain a body: a data stream of a specific content type. ## [Responses](https://square.github.io/okhttp/4.x/okhttp/okhttp3/-response/)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Feb 06 02:19:09 GMT 2022 - 3.9K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/internal/duplex/MockStreamHandler.kt
val task = serviceStreamTask(stream) results.add(task) task.run() } /** Returns a task that processes both request and response from [stream]. */ private fun serviceStreamTask(stream: Stream): FutureTask<Void> { return FutureTask<Void> { stream.requestBody.use { stream.responseBody.use { while (true) { val action = actions.poll() ?: break
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)