- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 55 for body (0.15 sec)
-
okhttp/src/test/java/okhttp3/WholeOperationTimeoutTest.kt
MockResponse.Builder() .body(BIG_ENOUGH_BODY) .build(), ) val request = Request.Builder() .url(server.url("/")) .build() val call = client.newCall(request) call.timeout().timeout(250, TimeUnit.MILLISECONDS) val response = call.execute() Thread.sleep(500) assertFailsWith<IOException> { response.body.source().readUtf8() }.also { expected ->
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache/CacheInterceptor.kt
cacheRequest: CacheRequest?, response: Response, ): Response { // Some apps return a null body; for compatibility we treat that like a null cache request. if (cacheRequest == null) return response val cacheBodyUnbuffered = cacheRequest.body() val source = response.body.source() val cacheBody = cacheBodyUnbuffered.buffer() val cacheWritingSource = object : Source {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Fri Mar 22 07:09:21 GMT 2024 - 10.2K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockResponse.kt
} fun body(body: Buffer) = body(body.toMockResponseBody()) fun body(body: MockResponseBody) = apply { setHeader("Content-Length", body.contentLength) this.body = body } /** Sets the response body to the UTF-8 encoded bytes of [body]. */ fun body(body: String): Builder = body(Buffer().writeUtf8(body))
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 13.3K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt
state = STATE_READING_RESPONSE_BODY return FixedLengthSource(length) } private fun newChunkedSource(url: HttpUrl): Source { check(state == STATE_OPEN_RESPONSE_BODY) { "state: $state" } state = STATE_READING_RESPONSE_BODY return ChunkedSource(url) } private fun newUnknownLengthSource(): Source { check(state == STATE_OPEN_RESPONSE_BODY) { "state: $state" }
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-logging-interceptor/src/test/java/okhttp3/logging/HttpLoggingInterceptorTest.kt
applicationLogs .assertLogEqual("--> POST $url (3-byte body)") .assertLogMatch(Regex("""<-- 200 OK $url \(\d+ms, 0-byte body\)""")) .assertNoMoreLogs() networkLogs .assertLogEqual("--> POST $url http/1.1 (3-byte body)") .assertLogMatch(Regex("""<-- 200 OK $url \(\d+ms, 0-byte body\)""")) .assertNoMoreLogs() } @Test fun basicResponseBody() {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 09:14:38 GMT 2024 - 37.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Response.kt
* before the entire HTTP response body has been consumed. */ @Throws(IOException::class) fun trailers(): Headers = trailersFn() /** * Peeks up to [byteCount] bytes from the response body and returns them as a new response * body. If fewer than [byteCount] bytes are in the response body, the full response body is
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/test/java/okhttp3/MultipartReaderTest.kt
"abc", ), ) assertThat(partAbc.body.readUtf8()).isEqualTo("abcd\r\nefgh") val partIjk = parts.nextPart()!! assertThat(partIjk.headers).isEqualTo( headersOf( "Content-Type", "text/plain; charset=utf-8", "Content-ID", "ijk", ), ) assertThat(partIjk.body.readUtf8()).isEqualTo("ijkl\r\nmnop\r\n")
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/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt
@Test @Throws(IOException::class) fun non101RetainsBody() { webServer.enqueue( MockResponse.Builder() .code(200) .body("Body") .build(), ) newWebSocket() clientListener.assertFailure( 200, "Body", ProtocolException::class.java, "Expected HTTP 101 response but was '200 OK'", ) } @Test @Throws(IOException::class)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 35.2K bytes - Viewed (1) -
okhttp/src/test/java/okhttp3/RouteFailureTest.kt
val refusedStream = MockResponse( socketPolicy = ResetStreamAtStart(ErrorCode.REFUSED_STREAM.httpCode), ) val bodyResponse = MockResponse(body = "body") @BeforeEach fun setUp( server: MockWebServer, @MockWebServerInstance("server2") server2: MockWebServer, ) { this.server1 = server this.server2 = server2
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 11.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/KotlinDeprecationErrorTest.kt
fun multipartBodyPart() { val multipartBody: MultipartBody = MultipartBody.Builder().build() val part: MultipartBody.Part = multipartBody.part(0) val headers: Headers? = part.headers() val body: RequestBody = part.body() } @Test @Disabled fun okHttpClient() { val client = OkHttpClient() val dispatcher: Dispatcher = client.dispatcher() val proxy: Proxy? = client.proxy()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 13.3K bytes - Viewed (0)