- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for MultiReader (0.3 sec)
-
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(); }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Feb 28 20:13:02 GMT 2023 - 2.4K bytes - Viewed (0) -
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
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Mar 06 16:56:10 GMT 2023 - 4.8K bytes - Viewed (0) -
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; }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed May 17 14:35:11 GMT 2023 - 22.4K bytes - Viewed (0) -
internal/s3select/csv/reader_contrib_test.go
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 38.5K bytes - Viewed (0) -
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)
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Feb 10 18:56:01 GMT 2023 - 51.5K bytes - Viewed (0) -
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) } }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 160K bytes - Viewed (0) -
api/go1.txt
pkg index/suffixarray, type Index struct pkg io, func Copy(Writer, Reader) (int64, error) pkg io, func CopyN(Writer, Reader, int64) (int64, error) pkg io, func LimitReader(Reader, int64) Reader pkg io, func MultiReader(...Reader) Reader pkg io, func MultiWriter(...Writer) Writer pkg io, func NewSectionReader(ReaderAt, int64, int64) *SectionReader pkg io, func Pipe() (*PipeReader, *PipeWriter)
Plain Text - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Wed Aug 14 18:58:28 GMT 2013 - 1.7M bytes - Viewed (1)