Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for once (0.31 sec)

  1. internal/s3select/csv/reader.go

    	input []byte          // raw input sent to the worker
    	dst   chan [][]string // result of block decode
    	err   error           // any error encountered will be set here
    }
    
    // Read - reads single record.
    // Once Read is called the previous record should no longer be referenced.
    func (r *Reader) Read(dst sql.Record) (sql.Record, error) {
    	// If we have have any records left, return these before any error.
    	for len(r.current) <= r.recordsRead {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 8.9K bytes
    - Viewed (0)
  2. src/archive/zip/reader.go

    	// The baseOffset field is the start of the zip file proper.
    	baseOffset int64
    
    	// fileList is a list of files sorted by ename,
    	// for use by the Open method.
    	fileListOnce sync.Once
    	fileList     []fileListEntry
    }
    
    // A ReadCloser is a [Reader] that must be closed when no longer needed.
    type ReadCloser struct {
    	f *os.File
    	Reader
    }
    
    // A File is a single file in a ZIP archive.
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Fri Oct 13 18:36:46 GMT 2023
    - 27.7K bytes
    - Viewed (0)
  3. internal/etag/reader.go

    // A Reader wraps an io.Reader and computes the
    // MD5 checksum of the read content as ETag.
    //
    // Optionally, a Reader can also verify that
    // the computed ETag matches an expected value.
    // Therefore, it compares both ETags once the
    // underlying io.Reader returns io.EOF.
    // If the computed ETag does not match the
    // expected ETag then Read returns a VerifyError.
    //
    // Reader implements the Tagger interface.
    type Reader struct {
    	src io.Reader
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 4.8K bytes
    - Viewed (0)
  4. internal/bucket/bandwidth/reader.go

    			tokens = need + hdr
    
    		} else { // part of header can be accommodated
    			r.opts.HeaderSize -= b - 1
    			need = 1 // to ensure we read at least one byte for every Read
    			tokens = b
    		}
    	} else { // all tokens go towards payload
    		need = int(math.Min(float64(b), float64(need)))
    		tokens = need
    	}
    
    	err = r.throttle.WaitN(r.ctx, tokens)
    	if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Sep 06 03:21:59 GMT 2023
    - 3.1K bytes
    - Viewed (0)
  5. src/archive/tar/reader.go

    	// files. Internally, the tar format often uses fake "files" to add meta
    	// data that describes the next file. These meta data "files" should not
    	// normally be visible to the outside. As such, this loop iterates through
    	// one or more "header files" until it finds a "normal file".
    	format := FormatUSTAR | FormatPAX | FormatGNU
    	for {
    		// Discard the remainder of the file and any padding.
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Fri Mar 08 01:59:14 GMT 2024
    - 26.8K bytes
    - Viewed (0)
Back to top