Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 161 - 170 of 514 for buffer (0.03 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top