- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 113 for Read (8.23 sec)
-
mockwebserver/src/main/kotlin/mockwebserver3/SocketPolicy.kt
* framing. Ignore the socket completely until the server is shut down. */ object StallSocketAtStart : SocketPolicy /** * Read the request but don't respond to it. Just keep the socket open. For testing read response * header timeout issue. */ object NoResponse : SocketPolicy /** * Fail HTTP/2 requests without processing them by sending [http2ErrorCode]. */
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 4.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/MultipartReader.kt
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: * * ```kotlin * val response: Response = call.execute()
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) -
okhttp/src/test/java/okhttp3/MultipartReaderTest.kt
) val part = parts.nextPart()!! assertThat(part.body.readUtf8()).isEqualTo("abcd\r\n--simple boundar\r\n\r\nefgh") assertThat(parts.nextPart()).isNull() } @Test fun `do not need to read entire part`() { val multipart = """ |--simple boundary | |abcd |efgh |ijkl |--simple boundary | |mnop |--simple boundary--
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 13.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http1/HeadersReader.kt
/** * Parse all headers delimited by "\r\n" until an empty line. This throws if headers exceed 256 KiB. */ class HeadersReader(val source: BufferedSource) { private var headerLimit = HEADER_LIMIT.toLong() /** Read a single line counted against the header size limit. */ fun readLine(): String { val line = source.readUtf8LineStrict(headerLimit) headerLimit -= line.length.toLong() return line }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 1.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Request.kt
/** * Attaches [tag] to the request using [T] as a key. Tags can be read from a request using * [Request.tag]. Use null to remove any existing tag assigned for [T]. * * Use this API to attach timing, debugging, or other application data to a request so that * you may read it in interceptors, event listeners, or callbacks. */ @JvmName("reifiedTag")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 04:17:44 GMT 2024 - 10.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Response.kt
* should not be read. */ @get:JvmName("networkResponse") val networkResponse: Response?, /** * Returns the raw response received from the cache. Will be null if this response didn't use * the cache. For conditional get requests the cache response and network response may both be * non-null. The body of the returned response should not be read. */
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 15.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt
@Throws(IOException::class) override fun read( sink: Buffer, byteCount: Long, ): Long { while (left == 0) { source.skip(padding.toLong()) padding = 0 if (flags and FLAG_END_HEADERS != 0) return -1L readContinuationHeader() // TODO: test case for empty continuation header? } val read = source.read(sink, minOf(byteCount, left.toLong()))
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) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
val response = call.execute() val inputStream = response.body.byteStream() assertThat(inputStream.read()).isEqualTo('A'.code) assertThat(inputStream.read()).isEqualTo('B'.code) assertThat(inputStream.read()).isEqualTo('C'.code) assertThat(inputStream.read()).isEqualTo(-1) assertThat(inputStream.read()).isEqualTo(-1) inputStream.close() } @ParameterizedTest
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 75.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/-UtilJvm.kt
* * Unfortunately Java's networking APIs don't offer a good health check, so we go on our own by * attempting to read with a short timeout. If the fails immediately we know the socket is * unhealthy. * * @param source the source used to read bytes from the socket. */ internal fun Socket.isHealthy(source: BufferedSource): Boolean { return try { val readTimeout = soTimeout try {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 09 12:33:05 GMT 2024 - 10.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/ResponseBody.kt
* class to read a response that is larger than the entire memory allocated to the current process. * It can even stream a response larger than the total storage on the current device, which is a * common requirement for video streaming applications. * * Because this class does not buffer the full response in memory, the application may not
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 (0)