- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 99 for buffer (0.15 sec)
-
okhttp/src/test/java/okhttp3/MultipartBodyTest.kt
assertThat(body.isOneShot()).isEqualTo(false) val buffer = Buffer() body.writeTo(buffer) assertThat(body.contentLength()).isEqualTo(buffer.size) assertThat(buffer.readUtf8()).isEqualTo(expected) val buffer2 = Buffer() body.writeTo(buffer2) assertThat(body.contentLength()).isEqualTo(buffer2.size) assertThat(buffer2.readUtf8()).isEqualTo(expected) } @Test
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.4K bytes - Viewed (0) -
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/main/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt
* to buffer chunks; typically by using a buffered sink with this sink. */ private inner class ChunkedSink : Sink { private val timeout = ForwardingTimeout(sink.timeout()) private var closed: Boolean = false override fun timeout(): Timeout = timeout override fun write( source: Buffer, byteCount: Long, ) {
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) -
docs/bigdata/README.md
fs.s3a.fast.upload.buffer=disk # Use disk as the buffer for uploads fs.s3a.fast.upload=true # Turn on fast upload mode fs.s3a.max.total.tasks=2048 # Maximum number of parallel tasks fs.s3a.multipart.size=512M # Size of each multipart chunk fs.s3a.multipart.threshold=512M # Size before using multipart uploads fs.s3a.socket.recv.buffer=65536 # Read socket buffer hint fs.s3a.socket.send.buffer=65536 # Write socket buffer hint
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Sep 29 04:28:45 GMT 2022 - 14.7K bytes - Viewed (0) -
okhttp-tls/src/test/java/okhttp3/tls/internal/der/DerTest.kt
derWriter.writeUtf8("a".repeat(201)) } assertThat(buffer.readByteString(3)).isEqualTo("1e81c9".decodeHex()) assertThat(buffer.readUtf8()).isEqualTo("a".repeat(201)) } @Test fun `decode primitive bit string`() { val buffer = Buffer() .write("0307040A3B5F291CD0".decodeHex()) val derReader = DerReader(buffer) derReader.read("test") { header ->
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 31.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Writer.kt
import okhttp3.internal.writeMedium import okio.Buffer import okio.BufferedSink /** Writes HTTP/2 transport frames. */ @Suppress("NAME_SHADOWING") class Http2Writer( private val sink: BufferedSink, private val client: Boolean, ) : Closeable { internal val lock: ReentrantLock = ReentrantLock() private val hpackBuffer: Buffer = Buffer() private var maxFrameSize: Int = INITIAL_MAX_FRAME_SIZE
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 11.3K bytes - Viewed (0) -
tensorflow/c/BUILD
Plain Text - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Wed Mar 27 18:00:18 GMT 2024 - 30.3K bytes - Viewed (0) -
okhttp-logging-interceptor/src/main/kotlin/okhttp3/logging/HttpLoggingInterceptor.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 09:14:38 GMT 2024 - 11.2K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/cache2/Relay.kt
) synchronized(this@Relay) { // Append new upstream bytes into the buffer. Trim it to its max size. buffer.write(upstreamBuffer, upstreamBytesRead) if (buffer.size > bufferMaxSize) { buffer.skip(buffer.size - bufferMaxSize) } // Now that the file and buffer have bytes, adjust upstreamPos. ******@****.***amPos += upstreamBytesRead }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache/CacheInterceptor.kt
import okhttp3.internal.http.HttpMethod import okhttp3.internal.http.RealResponseBody import okhttp3.internal.http.promisesBody import okhttp3.internal.stripBody import okio.Buffer import okio.Source import okio.Timeout import okio.buffer /** Serves requests from the cache and writes responses to the cache. */ class CacheInterceptor(internal val cache: Cache?) : Interceptor { @Throws(IOException::class)
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)