Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for NewSkipReader (0.11 sec)

  1. internal/ioutil/ioutil.go

    			}
    			n, err := s.Reader.Read(tmp[:l])
    			if err != nil {
    				return 0, err
    			}
    			s.skipCount -= int64(n)
    		}
    	}
    	return s.Reader.Read(p)
    }
    
    // NewSkipReader - creates a SkipReader
    func NewSkipReader(r io.Reader, n int64) io.Reader {
    	return &SkipReader{r, n}
    }
    
    // writerOnly hides an io.Writer value's optional ReadFrom method
    // from io.Copy.
    type writerOnly struct {
    	io.Writer
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  2. internal/ioutil/ioutil_test.go

    		{bytes.NewBuffer([]byte("abc")), 2, "c"},
    		{bytes.NewBuffer([]byte("abc")), 3, ""},
    		{bytes.NewBuffer([]byte("abc")), 4, ""},
    	}
    	for i, testCase := range testCases {
    		r := NewSkipReader(testCase.src, testCase.skipLen)
    		b, err := io.ReadAll(r)
    		if err != nil {
    			t.Errorf("Case %d: Unexpected err %v", i, err)
    		}
    		if string(b) != testCase.expected {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 22 23:07:14 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  3. cmd/object-api-utils.go

    				if err != nil {
    					// Call the cleanup funcs
    					for i := len(cFns) - 1; i >= 0; i-- {
    						cFns[i]()
    					}
    					return nil, err
    				}
    				if decryptSkip > 0 {
    					inputReader = ioutil.NewSkipReader(inputReader, decryptSkip)
    				}
    				oi.Size = decLength
    			}
    			// Decompression reader.
    			var dopts []s2.ReaderOption
    			if off > 0 || decOff > 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 37.1K bytes
    - Viewed (0)
  4. cmd/object-handlers_test.go

    		cumulativeSum := int64(0)
    		for _, p := range oi.partLengths {
    			readers = append(readers, NewDummyDataGen(p, cumulativeSum))
    			cumulativeSum += p
    		}
    
    		refReader := io.LimitReader(ioutilx.NewSkipReader(io.MultiReader(readers...), off), length)
    		if ok, msg := cmpReaders(refReader, rec.Body); !ok {
    			t.Fatalf("(%s) Object: %s Case %d ByteRange: %s --> data mismatch! (msg: %s)", instanceType, oi.objectName, i+1, byteRange, msg)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 20:10:44 UTC 2024
    - 163.2K bytes
    - Viewed (0)
Back to top