- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for unwrap (0.16 sec)
-
internal/s3select/json/reader.go
d := jstream.NewDecoder(readCloser, 0).ObjectAsKVS() return &Reader{ args: args, decoder: d, valueCh: d.Stream(), readCloser: readCloser, } } // syncReadCloser will wrap a readcloser and make it safe to call Close while // reads are running. type syncReadCloser struct { rc io.ReadCloser mu sync.Mutex } func (pr *syncReadCloser) Read(p []byte) (n int, err error) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 24 03:58:53 GMT 2022 - 3K bytes - Viewed (0) -
internal/hash/reader.go
} if r.size >= 0 && size >= 0 && r.size != size { return nil, SizeMismatch{Want: r.size, Got: size} } r.checksum = MD5 r.contentSHA256 = SHA256 if r.size < 0 && size >= 0 { r.src = etag.Wrap(ioutil.HardLimitReader(r.src, size), r.src) r.size = size } if r.actualSize <= 0 && actualSize >= 0 { r.actualSize = actualSize } return r, nil } if size >= 0 {
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/etag/reader.go
if r.Tagger == nil { return nil } return r.Tagger.ETag() } // Wrap returns an io.Reader that reads from the wrapped // io.Reader and implements the Tagger interaface. // // If content implements Tagger then the returned Reader // returns ETag of the content. Otherwise, it returns // nil as ETag. // // Wrap provides an adapter for io.Reader implementations // that don't implement the Tagger interface.
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) -
internal/s3select/simdj/reader.go
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)