- Sort Score
- Result 10 results
- Languages All
Results 411 - 420 of 979 for buffer (0.03 sec)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache/FaultHidingSink.kt
import java.io.IOException import okio.Buffer import okio.ForwardingSink import okio.Sink /** A sink that never throws IOExceptions, even if the underlying sink does. */ internal open class FaultHidingSink( delegate: Sink, val onException: (IOException) -> Unit, ) : ForwardingSink(delegate) { private var hasErrors = false override fun write( source: Buffer, byteCount: Long, ) {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 1.5K bytes - Viewed (0) -
okhttp/src/commonTest/kotlin/okhttp3/internal/publicsuffix/PublicSuffixDatabaseTest.kt
@Before fun setUp() { beforePublicSuffixTest() } @Test fun allPublicSuffixes() { val buffer = Buffer() FileSystem.SYSTEM.read(pathForTests) { val length = readInt() buffer.write(this, length.toLong()) } while (!buffer.exhausted()) { var publicSuffix = buffer.readUtf8LineStrict() if (publicSuffix.contains("*")) {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue May 27 22:00:49 UTC 2025 - 8.5K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http/CancelTest.kt
.Builder() .body( Buffer() .write(ByteArray(responseBodySize)), ).throttleBody(64 * 1024, 125, MILLISECONDS) // 500 Kbps .build(), ) val call = client.newCall(Request(server.url("/"))) val response = call.execute() cancelLater(call, 500) val responseBody = response.body.byteStream() val buffer = ByteArray(1024) assertFailsWith<IOException> {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 9.8K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/WebPlatformUrlTestData.kt
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 3.7K bytes - Viewed (0) -
src/main/java/jcifs/smb1/dcerpc/DcerpcSecurityProvider.java
* Wraps outgoing DCERPC message data for security protection * @param outgoing the buffer containing data to be wrapped * @throws DcerpcException if the wrapping operation fails */ void wrap(NdrBuffer outgoing) throws DcerpcException; /** * Unwraps incoming DCERPC message data after security processing * @param incoming the buffer containing data to be unwrapped
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 1.6K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Hpack.kt
import okhttp3.internal.http2.Header.Companion.TARGET_PATH import okhttp3.internal.http2.Header.Companion.TARGET_SCHEME import okhttp3.internal.unmodifiable import okio.Buffer import okio.BufferedSource import okio.ByteString import okio.Source import okio.buffer /** * Read and write HPACK v10. * * http://tools.ietf.org/html/draft-ietf-httpbis-header-compression-12 *
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon May 05 16:01:00 UTC 2025 - 22.4K bytes - Viewed (0) -
src/main/java/jcifs/smb1/netbios/SessionServicePacket.java
return HEADER_LENGTH; } int readHeaderWireFormat(final InputStream in, final byte[] buffer, int bufferIndex) throws IOException { type = buffer[bufferIndex] & 0xFF; bufferIndex++; length = ((buffer[bufferIndex] & 0x01) << 16) + readInt2(buffer, bufferIndex + 1); return HEADER_LENGTH; } abstract int writeTrailerWireFormat(byte[] dst, int dstIndex);
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 5.2K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance_gen_test.go
v := rebalanceInfo{} var buf bytes.Buffer msgp.Encode(&buf, &v) b.SetBytes(int64(buf.Len())) en := msgp.NewWriter(msgp.Nowhere) b.ReportAllocs() b.ResetTimer() for i := 0; i < b.N; i++ { v.EncodeMsg(en) } en.Flush() } func BenchmarkDecoderebalanceInfo(b *testing.B) { v := rebalanceInfo{} var buf bytes.Buffer msgp.Encode(&buf, &v) b.SetBytes(int64(buf.Len()))
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Oct 25 19:36:57 UTC 2022 - 11K bytes - Viewed (0) -
okhttp/src/commonTest/kotlin/okhttp3/CompressionInterceptorTest.kt
import okio.Buffer import okio.ByteString.Companion.encodeUtf8 import okio.GzipSink import okio.Source import okio.buffer import org.junit.jupiter.api.Test import org.junit.jupiter.api.extension.RegisterExtension class CompressionInterceptorTest { @RegisterExtension val clientTestRule = OkHttpClientTestRule() val source = Buffer().apply { write("Hello World".encodeUtf8())
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Aug 01 06:04:22 UTC 2025 - 3K bytes - Viewed (0) -
src/main/java/jcifs/dcerpc/UnicodeString.java
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 2.7K bytes - Viewed (0)