Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 74 for readBytes (0.58 sec)

  1. internal/ringbuffer/ring_buffer.go

    		c2 := n - c1
    		copy(p[c1:], r.buf[0:c2])
    	}
    	r.r = (r.r + n) % r.size
    
    	r.isFull = false
    
    	return n, r.readErr(true)
    }
    
    // ReadByte reads and returns the next byte from the input or ErrIsEmpty.
    func (r *RingBuffer) ReadByte() (b byte, err error) {
    	r.mu.Lock()
    	defer r.mu.Unlock()
    	if err = r.readErr(true); err != nil {
    		return 0, err
    	}
    	for r.w == r.r && !r.isFull {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 13.3K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/io/LittleEndianDataInputStream.java

      @Override
      public char readChar() throws IOException {
        return (char) readUnsignedShort();
      }
    
      @CanIgnoreReturnValue // to skip a byte
      @Override
      public byte readByte() throws IOException {
        return (byte) readUnsignedByte();
      }
    
      @CanIgnoreReturnValue // to skip a byte
      @Override
      public boolean readBoolean() throws IOException {
        return readUnsignedByte() != 0;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Feb 12 03:49:18 UTC 2025
    - 7.3K bytes
    - Viewed (0)
  3. src/main/java/jcifs/smb1/smb1/SmbRandomAccessFile.java

            if (read(tmp, 0, 1) < 0) {
                throw new SmbException("EOF");
            }
            return tmp[0] != (byte) 0x00;
        }
    
        @Override
        public final byte readByte() throws SmbException {
            if (read(tmp, 0, 1) < 0) {
                throw new SmbException("EOF");
            }
            return tmp[0];
        }
    
        @Override
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 14.1K bytes
    - Viewed (0)
  4. okhttp/src/jvmTest/kotlin/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 Dec 26 11:42:13 UTC 2025
    - Last Modified: Sat Nov 01 12:18:11 UTC 2025
    - 59.4K bytes
    - Viewed (0)
  5. 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 = toUnsignedInt(din.readByte());
          dataLength = din.readInt();
    
          /*
           * We document in BloomFilterStrategies that we must not change the ordering, and we have a
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 23 19:23:59 UTC 2025
    - 26.9K bytes
    - Viewed (0)
  6. 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 Dec 30 11:13:12 UTC 2025
    - Last Modified: Mon May 12 16:07:54 UTC 2025
    - 16.5K bytes
    - Viewed (0)
  7. 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: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 18.8K bytes
    - Viewed (0)
  8. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 43.4K bytes
    - Viewed (0)
  9. okhttp/src/jvmTest/kotlin/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 Dec 26 11:42:13 UTC 2025
    - Last Modified: Sat Jun 21 20:36:35 UTC 2025
    - 133.2K bytes
    - Viewed (0)
  10. 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 Dec 30 11:13:12 UTC 2025
    - Last Modified: Wed Aug 14 18:58:28 UTC 2013
    - 1.7M bytes
    - Viewed (0)
Back to top