- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 371 for buffer (0.19 sec)
-
src/bytes/buffer_test.go
// Confirm that when Reader panics, the empty buffer remains empty var buf2 Buffer defer func() { recover() check(t, "TestReadFromPanicReader (2)", &buf2, "") }() buf2.ReadFrom(panicReader{panic: true}) } func TestReadFromNegativeReader(t *testing.T) { var b Buffer defer func() { switch err := recover().(type) { case nil: t.Fatal("bytes.Buffer.ReadFrom didn't panic") case error:
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Apr 26 13:31:36 GMT 2024 - 18.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/cache2/FileOperatorTest.kt
val buffer = Buffer() operator.read(6, buffer, 21) operator.read(36, buffer, 1) operator.read(5, buffer, 5) operator.read(28, buffer, 8) operator.read(17, buffer, 10) operator.read(36, buffer, 2) operator.read(2, buffer, 4) operator.write(0, buffer, buffer.size) operator.read(0, buffer, 12) operator.read(47, buffer, 3) operator.read(45, buffer, 2) operator.read(47, buffer, 3)
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/MessageDeflaterInflaterTest.kt
val buffer = Buffer() buffer.write(byteString) deflate(buffer) return buffer.readByteString() } private fun MessageInflater.inflate(byteString: ByteString): ByteString { val buffer = Buffer() buffer.write(byteString) inflate(buffer) return buffer.readByteString() }
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Jan 06 05:31:00 GMT 2024 - 5K bytes - Viewed (0) -
android/guava/src/com/google/common/io/ByteStreams.java
int initialBufferSize = min(BUFFER_SIZE, max(128, Integer.highestOneBit(totalLen) * 2)); // Starting with an 8k buffer, double the size of each successive buffer. Smaller buffers // quadruple in size until they reach 8k, to minimize the number of small reads for longer // streams. Buffers are retained in a deque so that there's no copying between buffers while
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Jan 17 18:59:58 GMT 2024 - 29.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http/CancelTest.kt
@Throws(IOException::class) override fun configureSocket(socket: Socket): Socket { socket.sendBufferSize = SOCKET_BUFFER_SIZE socket.receiveBufferSize = SOCKET_BUFFER_SIZE return socket } }, ) .sslSocketFactory( handshakeCertificates.sslSocketFactory(),
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 9.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/cache2/RelayTest.kt
private fun sourceReader(source: Source?): Callable<ByteString> { return Callable { val buffer = Buffer() while (source!!.read(buffer, 16384) != -1L) { } source.close() buffer.readByteString() } } private fun assertFile( prefix: ByteString, upstreamSize: Long, metadataSize: Int,
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 8.1K bytes - Viewed (0) -
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 Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.4K bytes - Viewed (0) -
okhttp-logging-interceptor/src/test/java/okhttp3/logging/IsProbablyUtf8Test.kt
import okhttp3.logging.internal.isProbablyUtf8 import okio.Buffer import org.junit.jupiter.api.Test class IsProbablyUtf8Test { @Test fun isProbablyUtf8() { assertThat(Buffer().isProbablyUtf8()).isTrue() assertThat(Buffer().writeUtf8("abc").isProbablyUtf8()).isTrue() assertThat(Buffer().writeUtf8("new\r\nlines").isProbablyUtf8()).isTrue() assertThat(Buffer().writeUtf8("white\t space").isProbablyUtf8()).isTrue()
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 1.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http/ThreadInterruptTest.kt
serverSocket.setReceiveBufferSize(SOCKET_BUFFER_SIZE) return serverSocket } } client = clientTestRule.newClientBuilder() .socketFactory( object : DelegatingSocketFactory(getDefault()) { @Throws(IOException::class) override fun configureSocket(socket: Socket): Socket { socket.setSendBufferSize(SOCKET_BUFFER_SIZE)
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.6K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/UppercaseResponseInterceptor.kt
val read = delegate.read(buffer, byteCount) if (read != -1L) { sink.write(buffer.readByteString().toAsciiUppercase()) } return read } } }
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.8K bytes - Viewed (0)