- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 33 for Read (0.16 sec)
-
okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt
require(length < bytesOut.size - lastFrame.start) // Move everything from bytesOut into a new buffer. val fullBuffer = Buffer() bytesOut.read(fullBuffer, bytesOut.size) // Copy back all but what we're truncating. fullBuffer.read(bytesOut, lastFrame.start + length) outFrames.add(OutFrame(lastFrame.sequence, lastFrame.start, true)) return writer }
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) -
docs/changelogs/changelog_4x.md
* Upgrade: [Kotlin 1.8.21][kotlin_1_8_21]. ## Version 4.11.0 _2023-04-22_ * Fix: Don't fail the call when the response code is ‘HTTP 102 Processing’ or ‘HTTP 103 Early Hints’. * Fix: Read the response even if writing the request fails. This means you'll get a proper HTTP response even if the server rejects your request body. * Fix: Use literal IP addresses directly rather than passing them to `DnsOverHttps`.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 17 13:25:31 GMT 2024 - 25.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
} // Fill the receive buffer without holding any locks. val read = source.read(receiveBuffer, remainingByteCount) if (read == -1L) throw EOFException() remainingByteCount -= read // Move the received data to the read buffer to the reader can read it. If this source has // been closed since this read began we must discard the incoming data and tell the // connection we've done so.
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) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
* request was sent as intended. This method will block until the request is available, possibly * forever. * * @return the head of the request queue */ @Throws(InterruptedException::class) fun takeRequest(): RecordedRequest = requestQueue.take() /**
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 37.4K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/TestUtilJvm.kt
* detail is invisible to the caller, but subtle use of certain APIs may depend on these internal * structures. * * We make such subtle calls in [okhttp3.internal.ws.MessageInflater] because we try to read a * compressed stream that is terminated in a web socket frame even though the DEFLATE stream is * not terminated. * * Use this method to create a degenerate Okio Buffer where each byte is in a separate segment of
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 4.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/-ResponseCommon.kt
private val contentLength: Long, ) : ResponseBody(), Source { override fun contentType() = mediaType override fun contentLength() = contentLength override fun source() = buffer() override fun read( sink: Buffer, byteCount: Long, ): Long { throw IllegalStateException( """ |Unreadable ResponseBody! These Response objects have bodies that are stripped: | * Response.cacheResponse
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 13:24:48 GMT 2024 - 5.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CacheTest.kt
server.enqueue( MockResponse.Builder() .addHeader("Allow: GET, HEAD") .addHeader("Last-Modified: " + formatDate(-1, TimeUnit.HOURS)) .addHeader("Cache-Control: max-age=0") .body("A") .build(), ) server.enqueue( MockResponse.Builder() .addHeader("Allow: GET, HEAD, PUT") .code(HttpURLConnection.HTTP_NOT_MODIFIED) .build(),
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 108.6K bytes - Viewed (0) -
okhttp/api/okhttp.api
public static synthetic fun delete$default (Lokhttp3/Request$Builder;Lokhttp3/RequestBody;ILjava/lang/Object;)Lokhttp3/Request$Builder; public fun get ()Lokhttp3/Request$Builder; public fun head ()Lokhttp3/Request$Builder; public fun header (Ljava/lang/String;Ljava/lang/String;)Lokhttp3/Request$Builder; public fun headers (Lokhttp3/Headers;)Lokhttp3/Request$Builder;
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 13:41:01 GMT 2024 - 70.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/cache2/RelayTest.kt
val source = relay.newSource() val sourceBuffer = Buffer() assertThat(source!!.read(sourceBuffer, 5)).isEqualTo(5) assertThat(sourceBuffer.readUtf8()).isEqualTo("abcde") assertThat(source.read(sourceBuffer, 1024)).isEqualTo(8) assertThat(sourceBuffer.readUtf8()).isEqualTo("fghijklm") assertThat(source.read(sourceBuffer, 1024)).isEqualTo(-1) assertThat(sourceBuffer.size).isEqualTo(0) source.close()
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) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
val settings = Settings() settings[Settings.HEADER_TABLE_SIZE] = 0 val connection = connectWithSettings(client, settings) // Verify the peer's settings were read and applied. assertThat(connection.peerSettings.headerTableSize).isEqualTo(0) val writer = connection.writer assertThat(writer.hpackWriter.dynamicTableByteCount).isEqualTo(0)
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)