- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 1,736 for read (0.03 sec)
-
android/guava-tests/test/com/google/common/hash/HashingInputStreamTest.java
HashingInputStream in = new HashingInputStream(Hashing.md5(), buffer); byte[] buf = new byte[100]; int numOfByteRead = in.read(buf, 0, buf.length); assertEquals(-1, in.read()); // additional read assertEquals(4, numOfByteRead); assertEquals(expectedHash, in.hash()); } public void testHash_hashesCorrectlyForSkipping() throws Exception {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 02 16:24:50 UTC 2020 - 5K bytes - Viewed (0) -
guava-tests/test/com/google/common/hash/HashingInputStreamTest.java
HashingInputStream in = new HashingInputStream(Hashing.md5(), buffer); byte[] buf = new byte[100]; int numOfByteRead = in.read(buf, 0, buf.length); assertEquals(-1, in.read()); // additional read assertEquals(4, numOfByteRead); assertEquals(expectedHash, in.hash()); } public void testHash_hashesCorrectlyForSkipping() throws Exception {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 02 16:24:50 UTC 2020 - 5K bytes - Viewed (0) -
src/main/java/jcifs/pac/kerberos/KerberosToken.java
// yes, there really is non ASN.1/DER data inside the tagged object int read = 0; int readLow = stream.read() & 0xff; int readHigh = stream.read() & 0xff; read = ( readHigh << 8 ) + readLow; if ( read != 0x01 ) throw new PACDecodingException("Malformed kerberos token");
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Mon Oct 02 12:02:06 UTC 2023 - 3K bytes - Viewed (0) -
android/guava-tests/benchmark/com/google/common/io/ByteSourceAsCharSourceReadBenchmark.java
try (InputStreamReader reader = new InputStreamReader(byteSource.openStream(), cs)) { int nRead = 0; while (remaining > 0 && (nRead = reader.read(buffer, bufIndex, remaining)) != -1) { bufIndex += nRead; remaining -= nRead; } if (nRead == -1) { // we reached EOF return new String(buffer, 0, bufIndex); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Oct 10 19:45:10 UTC 2022 - 5.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache2/FileOperator.kt
import java.nio.channels.FileChannel import okio.Buffer /** * Read and write a target file. Unlike Okio's built-in `Okio.source(java.io.File file)` and `Okio.sink(java.io.File file)` * this class offers: * * * **Read/write:** read and write using the same operator. * * **Random access:** access any position within the file. * * **Shared channels:** read and write a file channel that's shared between
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2.4K bytes - Viewed (0) -
fastapi/datastructures.py
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Tue Apr 02 02:48:51 UTC 2024 - 5.6K bytes - Viewed (0) -
internal/dsync/drwmutex_test.go
panic("Failed to acquire read lock") } // fmt.Println("1st read lock acquired, waiting...") drwm2 := NewDRWMutex(ds, "simplelock") ctx2, cancel2 := context.WithCancel(context.Background()) if !drwm2.GetRLock(ctx2, cancel2, id, source, Options{Timeout: time.Second}) { panic("Failed to acquire read lock") } // fmt.Println("2nd read lock acquired, waiting...") go func() {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Dec 24 03:49:07 UTC 2022 - 9.7K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbRandomAccessFile.java
} @Override public int read () throws SmbException { if ( read(this.tmp, 0, 1) == -1 ) { return -1; } return this.tmp[ 0 ] & 0xFF; } @Override public int read ( byte b[] ) throws SmbException { return read(b, 0, b.length); } @Override public int read ( byte b[], int off, int len ) throws SmbException {
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Wed Jan 08 12:01:33 UTC 2020 - 18.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/TestInputStream.java
public boolean closed() { return closed; } @Override public int read() throws IOException { throwIf(closed); throwIf(READ_THROWS); return in.read(); } @Override public int read(byte[] b, int off, int len) throws IOException { throwIf(closed); throwIf(READ_THROWS); return in.read(b, off, len); } @Override public long skip(long n) throws IOException {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Dec 04 17:37:03 UTC 2017 - 2.5K bytes - Viewed (0) -
internal/ioutil/hardlimitreader.go
// A HardLimitedReader reads from R but limits the amount of // data returned to just N bytes. Each call to Read // updates N to reflect the new amount remaining. // Read returns EOF when N <= 0 or when the underlying R returns EOF. type HardLimitedReader struct { R io.Reader // underlying reader N int64 // max bytes remaining } func (l *HardLimitedReader) Read(p []byte) (n int, err error) { if l.N < 0 {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat May 06 02:53:12 UTC 2023 - 2K bytes - Viewed (0)