- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 231 for buffer (0.17 sec)
-
okhttp/src/test/java/okhttp3/MultipartReaderTest.kt
boundary = "simple boundary", source = Buffer().writeUtf8(multipart), ) assertThat(parts.nextPart()).isNotNull() assertThat(parts.nextPart()).isNull() assertThat(parts.nextPart()).isNull() } @Test fun `empty source`() { val parts = MultipartReader( boundary = "simple boundary", source = Buffer(), ) assertFailsWith<EOFException> {
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/SocksProxy.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 7.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ResponseJvmTest.kt
* most [BufferedSource] instances, but not of [Buffer]. */ private fun responseBody(content: String): ResponseBody { val data = Buffer().writeUtf8(content) val source: Source = object : Source { var closed = false override fun close() { closed = true } override fun read( sink: Buffer, byteCount: Long, ): Long {
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/WebPlatformUrlTestData.kt
} private fun unescape(s: String): String { return buildString { val buffer = Buffer().writeUtf8(s) while (!buffer.exhausted()) { val c = buffer.readUtf8CodePoint() if (c != '\\'.code) { append(c.toChar()) continue } when (buffer.readUtf8CodePoint()) { '\\'.code -> append('\\') '#'.code -> append('#')
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.7K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/UppercaseRequestInterceptor.kt
* limitations under the License. */ package okhttp3 import java.io.IOException import okhttp3.Interceptor.Chain import okio.Buffer import okio.BufferedSink import okio.ForwardingSink import okio.Sink import okio.buffer /** Rewrites the request body sent to the server to be all uppercase. */ class UppercaseRequestInterceptor : Interceptor { @Throws(IOException::class)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.9K bytes - Viewed (0) -
tensorflow/c/experimental/next_pluggable_device/BUILD
"//tensorflow/c:kernels_hdrs", "//tensorflow/c:tf_buffer_internal", "//tensorflow/c:tf_status_headers", "@local_xla//xla/pjrt/c:pjrt_c_api_hdrs", ], ) cc_library( name = "tensor_pjrt_buffer_util", srcs = ["tensor_pjrt_buffer_util.cc"], hdrs = ["tensor_pjrt_buffer_util.h"], visibility = ["//visibility:public"], deps = [
Plain Text - Registered: Tue Feb 27 12:39:08 GMT 2024 - Last Modified: Tue Jan 09 00:52:04 GMT 2024 - 3.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http/HttpHeaders.kt
} return commaFound } private fun Buffer.startsWith(prefix: Byte): Boolean = !exhausted() && this[0] == prefix /** * Reads a double-quoted string, unescaping quoted pairs like `\"` to the 2nd character in each * sequence. Returns the unescaped string, or null if the buffer isn't prefixed with a * double-quoted string. */ @Throws(EOFException::class) private fun Buffer.readQuotedString(): String? {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 7.2K bytes - Viewed (0) -
mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/MockResponse.kt
headersBuilder.removeAll(name) } fun getBody(): Buffer? = body?.clone() fun setBody(body: Buffer) = apply { setHeader("Content-Length", body.size) this.body = body.clone() // Defensive copy. } fun setBody(body: String): MockResponse = setBody(Buffer().writeUtf8(body)) fun setChunkedBody( body: Buffer, maxChunkSize: Int, ) = apply {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 7.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/idn/StringprepReader.kt
* limitations under the License. */ package okhttp3.internal.idn import okio.Buffer import okio.BufferedSource import okio.ByteString.Companion.encodeUtf8 import okio.FileSystem import okio.IOException import okio.Options import okio.Path import okio.buffer import okio.use class StringprepTablesReader( private val fileSystem: FileSystem, ) { /**
Plain Text - Registered: Fri Mar 29 11:42:11 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/MultipartReader.kt
import java.io.Closeable import java.io.IOException import java.net.ProtocolException import okhttp3.internal.http1.HeadersReader import okio.Buffer import okio.BufferedSource import okio.ByteString.Companion.encodeUtf8 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
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)