- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 27 for ResponseBody (0.17 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/-ResponseBodyCommon.kt
package okhttp3.internal import okhttp3.MediaType import okhttp3.ResponseBody import okhttp3.ResponseBody.Companion.asResponseBody import okio.Buffer import okio.BufferedSource import okio.ByteString import okio.IOException import okio.use internal fun ResponseBody.commonBytes() = commonConsumeSource(BufferedSource::readByteArray) { it.size }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http/RealResponseBody.kt
import okhttp3.ResponseBody import okio.BufferedSource class RealResponseBody( /** * Use a string to avoid parsing the content type until needed. This also defers problems caused * by malformed content types. */ private val contentTypeString: String?, private val contentLength: Long, private val source: BufferedSource, ) : ResponseBody() {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ResponseJvmTest.kt
*/ package okhttp3 import assertk.assertThat import assertk.assertions.isEmpty import assertk.assertions.isEqualTo import kotlin.test.assertFailsWith import okhttp3.ResponseBody.Companion.asResponseBody import okhttp3.ResponseBody.Companion.toResponseBody import okio.Buffer import okio.BufferedSource import okio.Source import okio.Timeout import okio.buffer import org.junit.jupiter.api.Test
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ResponseCommonTest.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/-ResponseCommon.kt
import okhttp3.CacheControl import okhttp3.Headers import okhttp3.MediaType import okhttp3.Protocol import okhttp3.Request import okhttp3.Response import okhttp3.ResponseBody import okhttp3.ResponseBody.Companion.asResponseBody import okhttp3.internal.http.HTTP_PERM_REDIRECT import okhttp3.internal.http.HTTP_TEMP_REDIRECT import okio.Buffer import okio.IOException import okio.Source import okio.Timeout
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-testing-support/src/main/kotlin/okhttp3/ForwardingResponseBody.kt
* limitations under the License. */ package okhttp3 import okio.BufferedSource open class ForwardingResponseBody(delegate: ResponseBody?) : ResponseBody() { private val delegate: ResponseBody fun delegate(): ResponseBody { return delegate } override fun contentType(): MediaType? { return delegate.contentType() } override fun contentLength(): Long {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.2K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/internal/duplex/MockStreamHandler.kt
s: String, responseSent: CountDownLatch = CountDownLatch(0), ) = apply { actions += { stream -> stream.responseBody.writeUtf8(s) stream.responseBody.flush() responseSent.countDown() } } fun exhaustResponse() = apply { actions += { stream -> stream.responseBody.close() } } fun sleep( duration: Long, unit: TimeUnit, ) = apply {
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) -
okhttp/src/test/java/okhttp3/ResponseBodyTest.kt
assertThat(source.exhausted()).isTrue() assertThat(source.readUtf8()).isEqualTo("") } @Test fun sourceClosesUnderlyingSource() { var closed = false val body: ResponseBody = object : ResponseBody() { override fun contentType(): MediaType? { return null } override fun contentLength(): Long { return 5 }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http/ThreadInterruptTest.kt
.build(), ) val response = call.execute() interruptLater(500) val responseBody = response.body.byteStream() val buffer = ByteArray(1024) assertFailsWith<IOException> { while (responseBody.read(buffer) != -1) { } } responseBody.close() } private fun sleep(delayMillis: Int) { try { Thread.sleep(delayMillis.toLong())
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketRecorder.kt
cls: Class<out IOException?>?, message: String?, ) { val event = nextEvent() as Failure assertThat(event.response!!.code).isEqualTo(code) if (body != null) { assertThat(event.responseBody).isEqualTo(body) } assertThat(event.t.javaClass).isEqualTo(cls) assertThat(event.t.message).isEqualTo(message) } /** Expose this recorder as a frame callback and shim in "ping" events. */
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.9K bytes - Viewed (0)