- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for ok (0.13 sec)
-
internal/hash/reader.go
} if size >= 0 { r := ioutil.HardLimitReader(src, size) if !disableMD5 { if _, ok := src.(etag.Tagger); !ok { src = etag.NewReader(ctx, r, MD5, forceMD5) } else { src = etag.Wrap(r, src) } } else { src = r } } else if _, ok := src.(etag.Tagger); !ok { if !disableMD5 { src = etag.NewReader(ctx, src, MD5, forceMD5) } } var h hash.Hash
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) -
internal/s3select/csv/reader.go
// If we have have any records left, return these before any error. for len(r.current) <= r.recordsRead { if r.err != nil { return nil, r.err } // Move to next block item, ok := <-r.queue if !ok { r.err = io.EOF return nil, r.err } //nolint:staticcheck // SA6002 Using pointer would allocate more since we would have to copy slice header before taking a pointer. r.csvDstPool.Put(r.current)
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) -
internal/s3select/simdj/reader.go
readerWg sync.WaitGroup } // Read - reads single record. func (r *Reader) Read(dst sql.Record) (sql.Record, error) { v, ok := <-r.decoded if !ok { if r.err != nil && *r.err != nil { return nil, errJSONParsingError(*r.err) } return nil, io.EOF } dstRec, ok := dst.(*Record) if !ok { dstRec = &Record{} } dstRec.object = v return dstRec, nil } // Close - closes underlying reader.
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) -
internal/etag/reader.go
// // // Now, we need an io.Reader that can access // // the ETag computed over the content. // reader := etag.Wrap(encryptedContent, content) func Wrap(wrapped, content io.Reader) io.Reader { if t, ok := content.(Tagger); ok { return wrapReader{ Reader: wrapped, Tagger: t, } } return wrapReader{ Reader: wrapped, } } // A Reader wraps an io.Reader and computes the
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) -
src/archive/zip/reader.go
isDir := len(file.Name) > 0 && file.Name[len(file.Name)-1] == '/' name := toValidName(file.Name) if name == "" { continue } if idx, ok := files[name]; ok { r.fileList[idx].isDup = true continue } if idx, ok := knownDirs[name]; ok { r.fileList[idx].isDup = true continue } for dir := path.Dir(name); dir != "."; dir = path.Dir(dir) { dirs[dir] = true }
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) -
src/archive/tar/reader.go
default: return n, nil } } func (sr *sparseFileReader) WriteTo(w io.Writer) (n int64, err error) { ws, ok := w.(io.WriteSeeker) if ok { if _, err := ws.Seek(0, io.SeekCurrent); err != nil { ok = false // Not all io.Seeker can really seek } } if !ok { return io.Copy(w, struct{ io.Reader }{sr}) } var writeLastByte bool pos0 := sr.pos
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)