Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 19 for readFrom (0.32 seconds)

  1. src/bufio/example_test.go

    	// Output: 1 2 3 4
    }
    
    // ExampleWriter_ReadFrom demonstrates how to use the ReadFrom method of Writer.
    func ExampleWriter_ReadFrom() {
    	var buf bytes.Buffer
    	writer := bufio.NewWriter(&buf)
    
    	data := "Hello, world!\nThis is a ReadFrom example."
    	reader := strings.NewReader(data)
    
    	n, err := writer.ReadFrom(reader)
    	if err != nil {
    		fmt.Println("ReadFrom Error:", err)
    		return
    	}
    
    	if err = writer.Flush(); err != nil {
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Fri Nov 01 21:52:12 GMT 2024
    - 5.5K bytes
    - Click Count (0)
  2. internal/http/response-recorder.go

    var ErrNotImplemented = errors.New("not implemented")
    
    // ReadFrom implements support for calling internal io.ReaderFrom implementations
    // returns an error if the underlying ResponseWriter does not implement io.ReaderFrom
    func (lrw *ResponseRecorder) ReadFrom(r io.Reader) (int64, error) {
    	if lrw.ReaderFrom != nil {
    		n, err := lrw.ReaderFrom.ReadFrom(r)
    		lrw.bytesWritten += int(n)
    		return n, err
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 5.5K bytes
    - Click Count (0)
  3. src/archive/tar/writer_test.go

    					}
    				case testReadFrom:
    					f := &testFile{ops: tf.ops}
    					got, err := tw.readFrom(f)
    					if _, ok := err.(testError); ok {
    						t.Errorf("test %d, ReadFrom(): %v", i, err)
    					} else if got != tf.wantCnt || !equalError(err, tf.wantErr) {
    						t.Errorf("test %d, ReadFrom() = (%d, %v), want (%d, %v)", i, got, err, tf.wantCnt, tf.wantErr)
    					}
    					if len(f.ops) > 0 {
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Mon Dec 15 16:34:13 GMT 2025
    - 40.2K bytes
    - Click Count (0)
  4. src/archive/tar/writer.go

    	if err != nil && err != ErrWriteTooLong {
    		tw.err = err
    	}
    	return n, err
    }
    
    // readFrom populates the content of the current file by reading from r.
    // The bytes read must match the number of remaining bytes in the current file.
    //
    // If the current file is sparse and r is an io.ReadSeeker,
    // then readFrom uses Seek to skip past holes defined in Header.SparseHoles,
    // assuming that skipped regions are all NULs.
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Mon Feb 03 16:38:43 GMT 2025
    - 19.7K bytes
    - Click Count (0)
  5. src/bufio/bufio_test.go

    	n, err := w.Write([]byte("0123456789"))
    	if n != 10 || err != nil {
    		t.Fatalf("Write returned (%v, %v), want (10, nil)", n, err)
    	}
    
    	// Use ReadFrom to read in some data.
    	n2, err := w.ReadFrom(strings.NewReader("abcdef"))
    	if n2 != 6 || err != nil {
    		t.Fatalf("ReadFrom returned (%v, %v), want (6, nil)", n2, err)
    	}
    }
    
    type emptyThenNonEmptyReader struct {
    	r io.Reader
    	n int
    }
    
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Fri Feb 07 01:08:54 GMT 2025
    - 51.6K bytes
    - Click Count (0)
  6. src/bufio/bufio.go

    	n := copy(b.buf[b.n:], s)
    	b.n += n
    	nn += n
    	return nn, nil
    }
    
    // ReadFrom implements [io.ReaderFrom]. If the underlying writer
    // supports the ReadFrom method, this calls the underlying ReadFrom.
    // If there is buffered data and an underlying ReadFrom, this fills
    // the buffer and writes it before calling ReadFrom.
    func (b *Writer) ReadFrom(r io.Reader) (n int64, err error) {
    	if b.err != nil {
    		return 0, b.err
    	}
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Fri Feb 06 17:28:40 GMT 2026
    - 22K bytes
    - Click Count (0)
  7. benchmarks/src/main/java/org/elasticsearch/benchmark/search/aggregations/bucket/terms/StringTermsSerializationBenchmark.java

                resultBuckets,
                null
            );
        }
    
        @Benchmark
        public DelayableWriteable<InternalAggregations> serialize() {
            return results.asSerialized(InternalAggregations::readFrom, REGISTRY);
        }
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Thu Aug 12 21:50:17 GMT 2021
    - 3K bytes
    - Click Count (0)
  8. src/bytes/buffer.go

    }
    
    // MinRead is the minimum slice size passed to a [Buffer.Read] call by
    // [Buffer.ReadFrom]. As long as the [Buffer] has at least MinRead bytes beyond
    // what is required to hold the contents of r, [Buffer.ReadFrom] will not grow the
    // underlying buffer.
    const MinRead = 512
    
    // ReadFrom reads data from r until EOF and appends it to the buffer, growing
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Fri Nov 14 19:01:17 GMT 2025
    - 16.5K bytes
    - Click Count (0)
  9. api/go1.15.txt

    pkg net/url, method (*URL) EscapedFragment() string
    pkg net/url, method (*URL) Redacted() string
    pkg net/url, type URL struct, RawFragment string
    pkg os, method (*File) ReadFrom(io.Reader) (int64, error)
    pkg os, var ErrDeadlineExceeded error
    pkg regexp, method (*Regexp) SubexpIndex(string) int
    pkg strconv, func FormatComplex(complex128, uint8, int, int) string
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Fri Jul 17 02:15:01 GMT 2020
    - 7.6K bytes
    - Click Count (0)
  10. src/bytes/reader_test.go

    	type nErr struct {
    		n   int64
    		err error
    	}
    	type justReader struct {
    		io.Reader
    	}
    	type justWriter struct {
    		io.Writer
    	}
    	discard := justWriter{io.Discard} // hide ReadFrom
    
    	var with, withOut nErr
    	with.n, with.err = io.Copy(discard, NewReader(nil))
    	withOut.n, withOut.err = io.Copy(discard, justReader{NewReader(nil)})
    	if with != withOut {
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Mon Dec 13 18:45:54 GMT 2021
    - 8K bytes
    - Click Count (0)
Back to Top