Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 361 - 370 of 505 for buffer (0.06 seconds)

  1. internal/s3select/json/preader.go

    		r.close = nil
    	}
    	r.recordsRead = len(r.current)
    	if r.err == nil {
    		r.err = io.EOF
    	}
    	return r.readCloser.Close()
    }
    
    // nextSplit will attempt to skip a number of bytes and
    // return the buffer until the next newline occurs.
    // The last block will be sent along with an io.EOF.
    func (r *PReader) nextSplit(skip int, dst []byte) ([]byte, error) {
    	if cap(dst) < skip {
    		dst = make([]byte, 0, skip+1024)
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 6.5K bytes
    - Click Count (0)
  2. cmd/xl-storage.go

    	}
    
    	if verifier == nil {
    		n, err = file.ReadAt(buffer, offset)
    		return int64(n), err
    	}
    
    	h := verifier.algorithm.New()
    	if _, err = io.Copy(h, io.LimitReader(file, offset)); err != nil {
    		return 0, err
    	}
    
    	if n, err = io.ReadFull(file, buffer); err != nil {
    		return int64(n), err
    	}
    
    	if _, err = h.Write(buffer); err != nil {
    		return 0, err
    	}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 91.7K bytes
    - Click Count (0)
  3. mockwebserver/src/test/java/mockwebserver3/MockWebServerTest.kt

    import okhttp3.RequestBody.Companion.toRequestBody
    import okhttp3.TestUtil.assumeNotWindows
    import okhttp3.testing.PlatformRule
    import okhttp3.tls.HandshakeCertificates
    import okhttp3.tls.HeldCertificate
    import okio.Buffer
    import okio.ByteString
    import okio.ByteString.Companion.encodeUtf8
    import org.junit.jupiter.api.AfterEach
    import org.junit.jupiter.api.Assertions.fail
    import org.junit.jupiter.api.BeforeEach
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sun Aug 03 22:38:00 GMT 2025
    - 28K bytes
    - Click Count (0)
  4. docs/features/interceptors.md

            return -1; // We don't know the compressed length in advance!
          }
    
          @Override public void writeTo(BufferedSink sink) throws IOException {
            BufferedSink gzipSink = Okio.buffer(new GzipSink(sink));
            body.writeTo(gzipSink);
            gzipSink.close();
          }
        };
      }
    }
    ```
    
    ### Rewriting Responses
    
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sun Feb 06 02:19:09 GMT 2022
    - 8.1K bytes
    - Click Count (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/CallTest.kt

            ).hostnameVerifier(RecordingHostnameVerifier())
            .build()
        server.useHttps(handshakeCertificates.sslSocketFactory())
      }
    
      private fun gzip(data: String): Buffer {
        val result = Buffer()
        val sink = GzipSink(result).buffer()
        sink.writeUtf8(data)
        sink.close()
        return result
      }
    
      private fun cancelLater(
        call: Call,
        delay: Long,
      ): Thread {
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 147.4K bytes
    - Click Count (0)
  6. guava/src/com/google/common/io/Files.java

       *     helpful predefined constants
       * @return the buffered reader
       */
      public static BufferedReader newReader(File file, Charset charset) throws FileNotFoundException {
        checkNotNull(file);
        checkNotNull(charset);
        return new BufferedReader(new InputStreamReader(new FileInputStream(file), charset));
      }
    
      /**
       * Returns a buffered writer that writes to a file using the given character set.
       *
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Sep 25 20:24:13 GMT 2025
    - 32.8K bytes
    - Click Count (0)
  7. docs/debugging/xl-meta/main.go

    								reconPartial(shards, k, parityOK, splitData, startOffset, offset, rs, shardConfig, splitFilled)
    							}
    
    							var buf bytes.Buffer
    							if err := rs.Join(&buf, splitFilled, m.size); err == nil {
    								m.filled = buf.Bytes()
    							}
    							buf = bytes.Buffer{}
    							if err := rs.Join(&buf, splitData, m.size); err == nil {
    								m.mapped = buf.Bytes()
    							}
    							for i, v := range m.filled {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 40.4K bytes
    - Click Count (0)
  8. internal/s3select/csv/reader.go

    		r.close = nil
    	}
    	r.recordsRead = len(r.current)
    	if r.err == nil {
    		r.err = io.EOF
    	}
    	return r.readCloser.Close()
    }
    
    // nextSplit will attempt to skip a number of bytes and
    // return the buffer until the next newline occurs.
    // The last block will be sent along with an io.EOF.
    func (r *Reader) nextSplit(skip int, dst []byte) ([]byte, error) {
    	if cap(dst) < skip {
    		dst = make([]byte, 0, skip+1024)
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 8.8K bytes
    - Click Count (0)
  9. src/archive/zip/reader_test.go

    	if ft.Content == nil && ft.File == "" && ft.Size > 0 {
    		if size != ft.Size {
    			t.Errorf("%v: uncompressed size %#x, want %#x", ft.Name, size, ft.Size)
    		}
    		r.Close()
    		return
    	}
    
    	var b bytes.Buffer
    	_, err = io.Copy(&b, r)
    	if err != ft.ContentErr {
    		t.Errorf("copying contents: %v (want %v)", err, ft.ContentErr)
    	}
    	if err != nil {
    		return
    	}
    	r.Close()
    
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Fri Oct 17 20:10:27 GMT 2025
    - 56.5K bytes
    - Click Count (0)
  10. android/guava-testlib/src/com/google/common/testing/FreshValueGenerator.java

    import java.lang.reflect.InvocationTargetException;
    import java.lang.reflect.Method;
    import java.lang.reflect.Type;
    import java.lang.reflect.TypeVariable;
    import java.math.BigDecimal;
    import java.math.BigInteger;
    import java.nio.Buffer;
    import java.nio.ByteBuffer;
    import java.nio.CharBuffer;
    import java.nio.DoubleBuffer;
    import java.nio.FloatBuffer;
    import java.nio.IntBuffer;
    import java.nio.LongBuffer;
    import java.nio.ShortBuffer;
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue May 13 17:27:14 GMT 2025
    - 28.1K bytes
    - Click Count (0)
Back to Top