- Sort Score
- Result 10 results
- Languages All
Results 391 - 400 of 979 for buffer (0.03 sec)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/MessageDeflater.kt
private val deflaterSink = DeflaterSink(deflatedBytes, deflater) /** Deflates [buffer] in place as described in RFC 7692 section 7.2.1. */ @Throws(IOException::class) fun deflate(buffer: Buffer) { require(deflatedBytes.size == 0L) if (noContextTakeover) { deflater.reset() } deflaterSink.write(buffer, buffer.size) deflaterSink.flush() if (deflatedBytes.endsWith(EMPTY_DEFLATE_BLOCK)) {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 2.1K bytes - Viewed (0) -
src/main/java/org/codelibs/core/message/MessageFormatter.java
Registered: Fri Sep 05 20:58:11 UTC 2025 - Last Modified: Thu Jul 31 08:16:49 UTC 2025 - 5.4K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/create/LeaseV1CreateContextResponse.java
@Override public int decode(byte[] buffer, int bufferIndex, int len) throws SMBProtocolDecodingException { int start = bufferIndex; if (len < 32) { throw new SMBProtocolDecodingException("Lease V1 context data too short: " + len); } // Read lease V1 data (32 bytes) byte[] keyBytes = new byte[16]; System.arraycopy(buffer, bufferIndex, keyBytes, 0, 16);
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 23 02:21:31 UTC 2025 - 2.8K bytes - Viewed (0) -
src/main/java/jcifs/netbios/SessionRequestPacket.java
@Override int readTrailerWireFormat(final InputStream in, final byte[] buffer, int bufferIndex) throws IOException { final int start = bufferIndex; if (in.read(buffer, bufferIndex, this.length) != this.length) { throw new IOException("invalid session request wire format"); } bufferIndex += this.calledName.readWireFormat(buffer, bufferIndex);
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 2.7K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/MultipartReaderTest.kt
repeat(100) { sink.writeUtf8(a1024x1024) } } }, ).build() val buffer = Buffer() multipartBody.writeTo(buffer) val multipartReader = MultipartReader(buffer, "foo") val onlyPart = multipartReader.nextPart()!! assertThat(onlyPart.headers).isEqualTo( headersOf( "header-name", "header-value",
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed May 28 02:11:14 UTC 2025 - 15.4K bytes - Viewed (0) -
src/main/java/jcifs/dcerpc/ndr/NdrBuffer.java
} /** * The underlying byte buffer containing the NDR data. */ public byte[] buf; /** * The starting position in the buffer. */ public int start; /** * The current position in the buffer. */ public int index; /** * The length of data in the buffer. */ public int length; /**
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 10.7K bytes - Viewed (0) -
compat/maven-artifact/src/main/java/org/apache/maven/artifact/repository/ArtifactRepositoryPolicy.java
@Override public String toString() { StringBuilder buffer = new StringBuilder(64); buffer.append("{enabled="); buffer.append(enabled); buffer.append(", checksums="); buffer.append(checksumPolicy); buffer.append(", updates="); buffer.append(updatePolicy); buffer.append('}'); return buffer.toString(); }
Registered: Sun Sep 07 03:35:12 UTC 2025 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 5.9K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/ResponseBody.kt
val buffer = Buffer().writeString(this, charset) return buffer.asResponseBody(finalContentType, buffer.size) } /** Returns a new response body that transmits this byte array. */ @JvmStatic @JvmName("create") fun ByteArray.toResponseBody(contentType: MediaType? = null): ResponseBody = Buffer() .write(this)
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue May 27 14:51:25 UTC 2025 - 11.6K bytes - Viewed (0) -
src/main/java/jcifs/SmbResourceException.java
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 5.6K bytes - Viewed (0) -
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:
Registered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Mon May 19 16:13:04 UTC 2025 - 18.6K bytes - Viewed (0)