- Sort Score
- Num 10 results
- Language All
Results 161 - 170 of 514 for buffer (0.03 seconds)
-
samples/static-server/src/main/java/okhttp3/sample/SampleServer.java
return new MockResponse() .setStatus("HTTP/1.1 200") .setBody(fileToBytes(file)) .addHeader("content-type: " + contentType(path)); } private Buffer fileToBytes(File file) throws IOException { Buffer result = new Buffer(); result.writeAll(Okio.source(file)); return result; } private String contentType(String path) { if (path.endsWith(".png")) return "image/png";
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Jan 02 02:50:44 GMT 2019 - 4.7K bytes - Click Count (0) -
compat/maven-model-builder/src/main/java/org/apache/maven/model/building/ModelBuildingException.java
} return null; } static String toMessage(String modelId, List<ModelProblem> problems) { StringWriter buffer = new StringWriter(1024); PrintWriter writer = new PrintWriter(buffer); writer.print(problems.size()); writer.print((problems.size() == 1) ? " problem was " : " problems were ");Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Wed Jul 23 17:27:08 GMT 2025 - 5.4K bytes - Click Count (0) -
compat/maven-model-builder/src/main/java/org/apache/maven/model/building/DefaultModelBuilder.java
StringBuilder buffer = new StringBuilder(256); buffer.append("'parent.relativePath'"); if (childModel != problems.getRootModel()) { buffer.append(" of POM ").append(ModelProblemUtils.toSourceHint(childModel)); } buffer.append(" points at ").append(groupId).append(':').append(artifactId);
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Sun Mar 30 23:08:08 GMT 2025 - 55.3K bytes - Click Count (0) -
android/guava/src/com/google/common/escape/CharEscaper.java
int slen = s.length(); // Get a destination buffer and setup some loop variables. char[] dest = Platform.charBufferFromThreadLocal(); int destSize = dest.length; int destIndex = 0; int lastEscape = 0; // Loop through the rest of the string, replacing when needed into the // destination buffer, which gets grown as needed as well. for (; index < slen; index++) {
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Feb 13 15:45:16 GMT 2025 - 6.7K bytes - Click Count (0) -
cmd/streaming-signature-v4_test.go
expectedErr error } tests := []testCase{ // Test - 1 valid buffer with CRLF. {bytes.NewReader([]byte("\r\n")), nil}, // Test - 2 invalid buffer with no CRLF. {bytes.NewReader([]byte("he")), errMalformedEncoding}, // Test - 3 invalid buffer with more characters. {bytes.NewReader([]byte("he\r\n")), errMalformedEncoding}, // Test - 4 smaller buffer than expected. {bytes.NewReader([]byte("h")), io.ErrUnexpectedEOF}, }Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 5.7K bytes - Click Count (0) -
kotlin-js-store/yarn.lock
dependencies: glob "^7.1.3" safe-buffer@^5.1.0: version "5.2.1" resolved "https://registry.yarnpkg.com/safe-buffer/-/safe-buffer-5.2.1.tgz#1eaf9fa9bdb1fdd4ec75f58f9cdb4e6b7827eec6" integrity sha512-rp3So07KcdmmKbGvgaNxQSJr7bGVSVk5S9Eq1F+ppbRo70+YeaDxkw5Dd8NPN+GD6bjnYm2VuPuCXmpuYvmCXQ== "safer-buffer@>= 2.1.2 < 3", "safer-buffer@>= 2.1.2 < 3.0.0": version "2.1.2"Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Sat Jul 22 12:28:51 GMT 2023 - 87.4K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/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 call: RealCall, internal val cache: Cache?, ) : Interceptor {
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Nov 05 18:28:35 GMT 2025 - 10.3K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/KotlinSourceModernTest.kt
mockResponse.headers = headersOf() mockResponse.trailers = headersOf() mockResponse = mockResponse.removeHeader("") var body: Buffer? = mockResponse.getBody() mockResponse = mockResponse.setBody(Buffer()) mockResponse = mockResponse.setChunkedBody(Buffer(), 0) mockResponse = mockResponse.setChunkedBody("", 0) var socketPolicy: SocketPolicy = mockResponse.socketPolicy
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Nov 05 18:28:35 GMT 2025 - 47K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/MockHttp2Peer.kt
import okhttp3.internal.closeQuietly import okio.Buffer import okio.BufferedSource import okio.ByteString import okio.buffer import okio.source /** Replays prerecorded outgoing frames and records incoming frames. */ class MockHttp2Peer : Closeable { private var frameCount = 0 private var client = false private val bytesOut = Buffer() private var writer = Http2Writer(bytesOut, client)Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 8.7K bytes - Click Count (0) -
internal/http/response-recorder.go
ttfbBody time.Duration StartTime time.Time // number of bytes written bytesWritten int // number of bytes of response headers written headerBytesWritten int // Internal recording buffer headers bytes.Buffer body bytes.Buffer // Indicate if headers are written in the log headersLogged bool } // Hijack - hijacks the underlying connection func (lrw *ResponseRecorder) Hijack() (net.Conn, *bufio.ReadWriter, error) {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 5.5K bytes - Click Count (0)