Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 1,736 for read (0.06 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. fastapi/datastructures.py

            You normally wouldn't use this from a file you read in a request.
    
            To be awaitable, compatible with async, this is run in threadpool.
            """
            return await super().write(data)
    
        async def read(
            self,
            size: Annotated[
                int,
                Doc(
                    """
                    The number of bytes to read from the file.
                    """
                ),
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Apr 02 02:48:51 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top