Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 73 for readBytes (0.15 sec)

  1. android/guava/src/com/google/common/hash/BloomFilter.java

          // add non-stateless strategies (for which we've reserved negative ordinals; see
          // Strategy.ordinal()).
          strategyOrdinal = din.readByte();
          numHashFunctions = UnsignedBytes.toInt(din.readByte());
          dataLength = din.readInt();
    
          Strategy strategy = BloomFilterStrategies.values()[strategyOrdinal];
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 23 16:45:30 UTC 2024
    - 26.6K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/internal/cache/DiskLruCacheTest.kt

        v1Creator.setString(1, "BBbb")
        v1Creator.commit()
    
        cache["k1"]!!.use { snapshot1 ->
          val inV1 = snapshot1.getSource(0).buffer()
          assertThat(inV1.readByte()).isEqualTo('A'.code.toByte())
          assertThat(inV1.readByte()).isEqualTo('A'.code.toByte())
    
          val v1Updater = cache.edit("k1")!!
          v1Updater.setString(0, "CCcc")
          v1Updater.setString(1, "DDdd")
          v1Updater.commit()
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 15 14:55:09 UTC 2024
    - 75.8K bytes
    - Viewed (0)
  3. src/main/java/jcifs/smb/SmbRandomAccessFile.java

            if ( ( read(this.tmp, 0, 1) ) < 0 ) {
                throw new SmbEndOfFileException();
            }
            return this.tmp[ 0 ] != (byte) 0x00;
        }
    
    
        @Override
        public final byte readByte () throws SmbException {
            if ( ( read(this.tmp, 0, 1) ) < 0 ) {
                throw new SmbEndOfFileException();
            }
            return this.tmp[ 0 ];
        }
    
    
        @Override
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Wed Jan 08 12:01:33 UTC 2020
    - 18.5K bytes
    - Viewed (0)
  4. src/bytes/example_test.go

    	fmt.Println(string(rdbuf))
    	// Output:
    	// 1
    	// bcde
    	// a
    }
    
    func ExampleBuffer_ReadByte() {
    	var b bytes.Buffer
    	b.Grow(64)
    	b.Write([]byte("abcde"))
    	c, err := b.ReadByte()
    	if err != nil {
    		panic(err)
    	}
    	fmt.Println(c)
    	fmt.Println(b.String())
    	// Output:
    	// 97
    	// bcde
    }
    
    func ExampleClone() {
    	b := []byte("abc")
    	clone := bytes.Clone(b)
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Aug 07 17:22:36 UTC 2024
    - 14.9K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/URLConnectionTest.kt

        source.timeout().timeout(1000, TimeUnit.MILLISECONDS)
        assertThat(source.readByte()).isEqualTo('A'.code.toByte())
        assertThat(source.readByte()).isEqualTo('B'.code.toByte())
        assertThat(source.readByte()).isEqualTo('C'.code.toByte())
        assertFailsWith<SocketTimeoutException> {
          source.readByte() // If Content-Length was accurate, this would return -1 immediately.
        }
        source.close()
      }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 131.7K bytes
    - Viewed (0)
  6. api/go1.txt

    pkg io, method (*SectionReader) Size() int64
    pkg io, type ByteReader interface { ReadByte }
    pkg io, type ByteReader interface, ReadByte() (uint8, error)
    pkg io, type ByteScanner interface { ReadByte, UnreadByte }
    pkg io, type ByteScanner interface, ReadByte() (uint8, error)
    pkg io, type ByteScanner interface, UnreadByte() error
    pkg io, type Closer interface { Close }
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Aug 14 18:58:28 UTC 2013
    - 1.7M bytes
    - Viewed (0)
  7. docs/metrics/prometheus/list.md

    | `minio_node_io_read_bytes`                 | Total bytes read by the process from the underlying storage system, /proc/[pid]/io read_bytes.                  |
    | `minio_node_io_wchar_bytes`                | Total bytes written by the process to the underlying storage system including page cache, /proc/[pid]/io wchar. |
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:48:51 UTC 2024
    - 43.3K bytes
    - Viewed (0)
  8. docs/metrics/v3.md

    | `minio_system_process_io_read_bytes`               | Total bytes read by the process from the underlying storage system, /proc/[pid]/io read_bytes. <br><br>Type: counter                  | `server` |
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Aug 02 22:30:11 UTC 2024
    - 45.2K bytes
    - Viewed (0)
  9. test-site/activator-launch-1.3.2.jar

    plugins.repository.TransferListener { void Ivy$1(); public final void transferProgress(plugins.repository.TransferEvent); } org/apache/ivy/util/CopyProgressEvent.class package org.apache.ivy.util; public final synchronized class CopyProgressEvent { private int readBytes; public void CopyProgressEvent(); protected final CopyProgressEvent update$565320f6(int); public final int getReadBytes(); } org/apache/ivy/util/AbstractMessageLogge.class package org.apache.ivy.util; public abstract synchronized class AbstractMessageLogge...
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Mon Apr 20 08:41:37 UTC 2015
    - 1.2M bytes
    - Viewed (0)
  10. cmd/storage-rest-server.go

    // has been used.
    // The returned reader contains the payload.
    func waitForHTTPResponse(respBody io.Reader) (io.Reader, error) {
    	reader := bufio.NewReader(respBody)
    	for {
    		b, err := reader.ReadByte()
    		if err != nil {
    			return nil, err
    		}
    		// Check if we have a response ready or a filler byte.
    		switch b {
    		case 0:
    			return reader, nil
    		case 1:
    			errorText, err := io.ReadAll(reader)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 45.7K bytes
    - Viewed (0)
Back to top