Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for _new (0.19 sec)

  1. src/bytes/reader.go

    }
    
    // UnreadRune complements [Reader.ReadRune] in implementing the [io.RuneScanner] interface.
    func (r *Reader) UnreadRune() error {
    	if r.i <= 0 {
    		return errors.New("bytes.Reader.UnreadRune: at beginning of slice")
    	}
    	if r.prevRune < 0 {
    		return errors.New("bytes.Reader.UnreadRune: previous operation was not ReadRune")
    	}
    	r.i = int64(r.prevRune)
    	r.prevRune = -1
    	return nil
    }
    
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Fri Oct 13 17:10:31 GMT 2023
    - 3.9K bytes
    - Viewed (1)
  2. internal/etag/reader.go

    //
    // Reader implements the Tagger interface.
    type Reader struct {
    	src io.Reader
    
    	md5      hash.Hash
    	checksum ETag
    
    	readN int64
    }
    
    // NewReader returns a new Reader that computes the
    // MD5 checksum of the content read from r as ETag.
    //
    // If the provided etag is not nil the returned
    // Reader compares the etag with the computed
    // MD5 sum once the r returns io.EOF.
    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)
  3. internal/s3select/simdj/reader.go

    				}
    			default:
    				err = fmt.Errorf("unexpected root json type:%v", typ)
    				r.err = &err
    				return
    			}
    		}
    		if in.Error == io.EOF {
    			return
    		}
    	}
    }
    
    // NewReader - creates new JSON reader using readCloser.
    func NewReader(readCloser io.ReadCloser, args *json.ReaderArgs) *Reader {
    	r := Reader{
    		args:       args,
    		readCloser: &safeCloser{r: io.Reader(readCloser)},
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue May 30 17:02:22 GMT 2023
    - 4.9K bytes
    - Viewed (0)
  4. src/archive/tar/reader.go

    	// ensure that this error is sticky.
    	err error
    }
    
    type fileReader interface {
    	io.Reader
    	fileState
    
    	WriteTo(io.Writer) (int64, error)
    }
    
    // NewReader creates a new [Reader] reading from r.
    func NewReader(r io.Reader) *Reader {
    	return &Reader{r: r, curr: &regFileReader{r, 0}}
    }
    
    // Next advances to the next entry in the tar archive.
    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)
  5. src/archive/zip/reader.go

    	"path/filepath"
    	"sort"
    	"strings"
    	"sync"
    	"time"
    )
    
    var zipinsecurepath = godebug.New("zipinsecurepath")
    
    var (
    	ErrFormat       = errors.New("zip: not a valid zip file")
    	ErrAlgorithm    = errors.New("zip: unsupported compression algorithm")
    	ErrChecksum     = errors.New("zip: checksum error")
    	ErrInsecurePath = errors.New("zip: insecure file path")
    )
    
    // A Reader serves content from a ZIP archive.
    type Reader struct {
    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)
  6. internal/hash/reader.go

    	if len(SHA256) != 0 {
    		h = sha256.New()
    	}
    	return &Reader{
    		src:           src,
    		size:          size,
    		actualSize:    actualSize,
    		checksum:      MD5,
    		contentSHA256: SHA256,
    		sha256:        h,
    		disableMD5:    disableMD5,
    	}, nil
    }
    
    // ErrInvalidChecksum is returned when an invalid checksum is provided in headers.
    var ErrInvalidChecksum = errors.New("invalid checksum")
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 18 17:00:54 GMT 2023
    - 10.8K bytes
    - Viewed (0)
  7. internal/s3select/csv/reader.go

    		if r.args.FileHeaderInfo == use {
    			// Copy column names since records will be reused.
    			columns := append(make([]string, 0, len(record)), record...)
    			r.columnNames = columns
    		}
    	}
    
    	r.bufferPool.New = func() interface{} {
    		return make([]byte, csvSplitSize+1024)
    	}
    
    	// Return first block
    	next, nextErr := r.nextSplit(csvSplitSize, r.bufferPool.Get().([]byte))
    	// Check if first block is valid.
    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)
Back to top