- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 585 for readers (0.21 sec)
-
mockwebserver/src/test/java/mockwebserver3/MockWebServerTest.kt
// treats an incomplete response body as a ProtocolException. } } private fun headersToList(response: MockResponse.Builder): List<String> { val headers = response.build().headers return headers.map { (key, value) -> "$key: $value" }.toList() } @Test fun shutdownWithoutStart() { val server = MockWebServer() server.shutdown() } @Test
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 23.5K bytes - Viewed (0) -
mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/MockWebServerTest.kt
} } private fun headersToList(response: MockResponse): List<String> { val headers = response.headers val size = headers.size val headerList: MutableList<String> = ArrayList(size) for (i in 0 until size) { headerList.add(headers.name(i) + ": " + headers.value(i)) } return headerList } @Test fun shutdownWithoutStart() {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 21.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/MultipartReaderTest.kt
body.writeTo(bodyContent) val reader = MultipartReader(bodyContent, "boundary") val quickPart = reader.nextPart()!! assertThat(quickPart.headers).isEqualTo( headersOf( "Content-Type", "text/plain; charset=utf-8", ), ) assertThat(quickPart.body.readUtf8()).isEqualTo("Quick") val brownPart = reader.nextPart()!! assertThat(brownPart.headers).isEqualTo(
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) -
cmd/object-handlers.go
compressMetadata[ReservedMetadataPrefix+"actual-size"] = strconv.FormatInt(actualSize, 10) reader = etag.NewReader(ctx, reader, nil, nil) wantEncryption := crypto.Requested(r.Header) s2c, cb := newS2CompressReader(reader, actualSize, wantEncryption) dstOpts.IndexCB = cb defer s2c.Close() reader = etag.Wrap(s2c, reader) length = -1 } else { delete(srcInfo.UserDefined, ReservedMetadataPrefix+"compression")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 20:15:54 GMT 2024 - 125.2K bytes - Viewed (0) -
cmd/object-multipart-handlers.go
var idxCb func() []byte if isCompressed { wantEncryption := crypto.Requested(r.Header) || isEncrypted s2c, cb := newS2CompressReader(reader, actualPartSize, wantEncryption) idxCb = cb defer s2c.Close() reader = etag.Wrap(s2c, reader) length = -1 } srcInfo.Reader, err = hash.NewReader(ctx, reader, length, "", "", actualPartSize) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 39K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/HeadersJvmTest.kt
val expected = Instant.ofEpochMilli(0L) val headers = Headers.Builder() .add("Test-Instant", expected) .build() assertThat(headers["Test-Instant"]).isEqualTo("Thu, 01 Jan 1970 00:00:00 GMT") assertThat(headers.getInstant("Test-Instant")).isEqualTo(expected) } @Test fun setDate() { val expected = Date(1000) val headers = Headers.Builder() .add("testDate", Date(0L))
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.6K bytes - Viewed (0) -
internal/bucket/object/lock/lock.go
// IsObjectLockGovernanceBypassSet returns true if object lock governance bypass header is set. func IsObjectLockGovernanceBypassSet(h http.Header) bool { return strings.EqualFold(h.Get(AmzObjectLockBypassRetGovernance), "true") } // IsObjectLockRequested returns true if legal hold or object lock retention headers are requested. func IsObjectLockRequested(h http.Header) bool {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 17.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt
check(type == -1) this.type = Http2.TYPE_SETTINGS this.ack = true } override fun headers( inFinished: Boolean, streamId: Int, associatedStreamId: Int, headerBlock: List<Header>, ) { check(type == -1) this.type = Http2.TYPE_HEADERS this.inFinished = inFinished this.streamId = streamId this.associatedStreamId = associatedStreamId
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/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
internal val reader: Http2Reader, ) : Http2Reader.Handler, () -> Unit { override fun invoke() { var connectionErrorCode = ErrorCode.INTERNAL_ERROR var streamErrorCode = ErrorCode.INTERNAL_ERROR var errorException: IOException? = null try { reader.readConnectionPreface(this) while (reader.nextFrame(false, this)) { }
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/http2/Header.kt
* limitations under the License. */ package okhttp3.internal.http2 import okio.ByteString import okio.ByteString.Companion.encodeUtf8 /** HTTP header: the name is an ASCII string, but the value can be UTF-8. */ data class Header( /** Name in case-insensitive ASCII encoding. */ @JvmField val name: ByteString, /** Value in UTF-8 encoding. */ @JvmField val value: ByteString, ) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2K bytes - Viewed (0)