Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for MultiReader (0.08 sec)

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

     *
     * @author Bin Zhu
     * @since 1.0
     */
    @J2ktIncompatible
    @GwtIncompatible
    @ElementTypesAreNonnullByDefault
    class MultiReader extends Reader {
      private final Iterator<? extends CharSource> it;
      @CheckForNull private Reader current;
    
      MultiReader(Iterator<? extends CharSource> readers) throws IOException {
        this.it = readers;
        advance();
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Feb 28 20:13:02 UTC 2023
    - 2.4K bytes
    - Viewed (0)
  2. internal/config/crypto.go

    	}
    	header[0] = Version
    	binary.LittleEndian.PutUint32(header[1:], uint32(len(metadata)))
    	buffer.Write(header[:])
    	buffer.Write(metadata)
    
    	return io.MultiReader(
    		&buffer,
    		stream.EncryptReader(plaintext, nonce, nil),
    	), nil
    }
    
    // Decrypt decrypts the ciphertext using a key managed by the KMS.
    // The same context that have been used during encryption must be
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 07 23:55:37 UTC 2024
    - 5K 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 31 14:20:11 UTC 2024
    - 25.5K 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 Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Nov 01 21:52:12 UTC 2024
    - 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 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