Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for MultiReader (0.06 sec)

  1. android/guava/src/com/google/common/io/MultiReader.java

    /**
     * A {@link Reader} that concatenates multiple readers.
     *
     * @author Bin Zhu
     * @since 1.0
     */
    @J2ktIncompatible
    @GwtIncompatible
    final class MultiReader extends Reader {
      private final Iterator<? extends CharSource> it;
      private @Nullable Reader current;
    
      MultiReader(Iterator<? extends CharSource> readers) throws IOException {
        this.it = readers;
        advance();
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:37:28 UTC 2025
    - 2.4K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/io/CharSource.java

        ConcatenatedCharSource(Iterable<? extends CharSource> sources) {
          this.sources = checkNotNull(sources);
        }
    
        @Override
        public Reader openStream() throws IOException {
          return new MultiReader(sources.iterator());
        }
    
        @Override
        public boolean isEmpty() throws IOException {
          for (CharSource source : sources) {
            if (!source.isEmpty()) {
              return false;
            }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 25.7K bytes
    - Viewed (0)
  3. guava/src/com/google/common/io/CharSource.java

        ConcatenatedCharSource(Iterable<? extends CharSource> sources) {
          this.sources = checkNotNull(sources);
        }
    
        @Override
        public Reader openStream() throws IOException {
          return new MultiReader(sources.iterator());
        }
    
        @Override
        public boolean isEmpty() throws IOException {
          for (CharSource source : sources) {
            if (!source.isEmpty()) {
              return false;
            }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 25.3K bytes
    - Viewed (0)
  4. src/bufio/bufio_test.go

    	}
    }
    
    func TestReadZero(t *testing.T) {
    	for _, size := range []int{100, 2} {
    		t.Run(fmt.Sprintf("bufsize=%d", size), func(t *testing.T) {
    			r := io.MultiReader(strings.NewReader("abc"), &emptyThenNonEmptyReader{r: strings.NewReader("def"), n: 1})
    			br := NewReaderSize(r, size)
    			want := func(s string, wantErr error) {
    				p := make([]byte, 50)
    				n, err := br.Read(p)
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Fri Feb 07 01:08:54 UTC 2025
    - 51.6K bytes
    - Viewed (0)
  5. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 163.1K bytes
    - Viewed (0)
  6. lib/fips140/v1.0.0.zip

    t.Cleanup(func() { testingOnlyRejection = nil }) var loopCount int testingOnlyRejection = func() { loopCount++ } // A sequence of all ones will generate 2^N-1, which should be rejected. // (Unless, for example, we are masking too many bits.) r := io.MultiReader(bytes.NewReader(bytes.Repeat([]byte{0xff}, 100)), rand.Reader) if k, p, err := randomPoint(c, func(b []byte) error { _, err := r.Read(b) return err }); err != nil { t.Fatal(err) } else if k.IsZero() == 1 { t.Error("k is zero") } else if p.Bytes()[0]...
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Wed Jan 29 15:10:35 UTC 2025
    - 635K bytes
    - Viewed (0)
Back to top