- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 74 for readBytes (0.58 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)