read_bytes - Code Search

okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Hpack.kt

          dynamicTable[index] = entry
        }
        dynamicTableByteCount += delta
      }

      @Throws(IOException::class)
      private fun readByte(): Int = source.readByte() and 0xff

      @Throws(IOException::class)
      fun readInt(
        firstByte: Int,
        prefixMask: Int,
      ): Int {
        val prefix = firstByte and prefixMask

Created: Fri Apr 03 11:42:14 GMT 2026

- Last Modified: Sun Mar 15 09:02:18 GMT 2026

- 23.2K bytes

- Click Count (0)

github.com/golang/go

src/bytes/reader.go

	n = copy(b, r.s[off:])
	if n < len(b) {
		err = io.EOF
	}
	return
}

// ReadByte implements the [io.ByteReader] interface.
func (r *Reader) ReadByte() (byte, error) {
	r.prevRune = -1
	if r.i >= int64(len(r.s)) {
		return 0, io.EOF
	}
	b := r.s[r.i]
	r.i++
	return b, nil
}

// UnreadByte complements [Reader.ReadByte] in implementing the [io.ByteScanner] interface.
func (r *Reader) UnreadByte() error {

Created: Tue Apr 07 11:13:11 GMT 2026

- Last Modified: Tue Jul 16 18:17:37 GMT 2024

- 3.9K bytes

- Click Count (0)

github.com/minio/minio

cmd/streaming-signature-v4.go

		cr.err = errMalformedEncoding
		return n, cr.err
	}
	b, err := cr.reader.ReadByte()
	if err == io.EOF {
		err = io.ErrUnexpectedEOF
	}
	if err != nil {
		cr.err = err
		return n, cr.err
	}
	if b != '\r' {
		cr.err = errMalformedEncoding
		return n, cr.err
	}
	b, err = cr.reader.ReadByte()
	if err == io.EOF {
		err = io.ErrUnexpectedEOF
	}
	if err != nil {
		cr.err = err

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Sun Sep 28 20:59:21 GMT 2025

- 18.2K bytes

- Click Count (0)

github.com/square/okhttp

okhttp-idna-mapping-table/src/main/kotlin/okhttp3/internal/idn/SimpleIdnaMappingTable.kt

      when (select(optionsDot)) {
        DELIMITER_DOT -> {
          if (readByte() != '.'.code.toByte()) throw IOException("expected '..'")
          readHexadecimalUnsignedLong()
        }

        else -> {
          sourceCodePoint0
        }
      }

    skipWhitespace()
    if (readByte() != ';'.code.toByte()) throw IOException("expected ';'")

    // "valid" or "mapped"

Created: Fri Apr 03 11:42:14 GMT 2026

- Last Modified: Tue Jan 27 09:00:39 GMT 2026

- 6.9K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/test/java/jcifs/internal/smb1/com/SmbComTreeDisconnectTest.java

        assertNotNull(readParameterWords);

        Method readBytes = clazz.getDeclaredMethod("readBytesWireFormat", byte[].class, int.class);
        assertNotNull(readBytes);

        Method toString = clazz.getDeclaredMethod("toString");
        assertNotNull(toString);
    }

Created: Sun Apr 05 00:10:12 GMT 2026

- Last Modified: Thu Aug 14 05:31:44 GMT 2025

- 18.5K bytes

- Click Count (0)

github.com/google/guava

android/guava-tests/test/com/google/common/io/LittleEndianDataInputStreamTest.java

    in.readFully(b);
    assertEquals(-100, b[0]);
    assertEquals(100, b[1]);
    assertEquals(true, in.readBoolean());
    assertEquals(false, in.readBoolean());
    assertEquals(100, in.readByte());
    assertEquals(-100, in.readByte());
    assertEquals(200, in.readUnsignedByte());
    assertEquals('\u6100', in.readChar());
    assertEquals(-12150, in.readShort());
    assertEquals(20675, in.readUnsignedShort());

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Tue Mar 17 19:26:39 GMT 2026

- 4.9K bytes

- Click Count (0)

github.com/square/okhttp

okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/-UtilCommon.kt

  writeByte(medium.ushr(8) and 0xff)
  writeByte(medium and 0xff)
}

@Throws(IOException::class)
internal fun BufferedSource.readMedium(): Int =
  (
    readByte() and 0xff shl 16
      or (readByte() and 0xff shl 8)
      or (readByte() and 0xff)
  )

/** Run [block] until it either throws an [IOException] or completes. */
internal inline fun ignoreIoExceptions(block: () -> Unit) {
  try {
    block()

Created: Fri Apr 03 11:42:14 GMT 2026

- Last Modified: Mon May 05 16:01:00 GMT 2025

- 10.1K bytes

- Click Count (0)

github.com/tiangolo/fastapi

docs/en/docs/reference/websockets.md

            - receive_text
            - receive_bytes
            - receive_json
            - iter_text
            - iter_bytes
            - iter_json
            - send_text
            - send_bytes
            - send_json
            - close

## WebSockets - additional classes

Additional classes for handling WebSockets.

Provided directly by Starlette, but you can import it from `fastapi`:

Created: Sun Apr 05 07:19:11 GMT 2026

- Last Modified: Wed Feb 04 12:41:54 GMT 2026

- 2K bytes

- Click Count (0)

github.com/google/guava

android/guava-tests/test/com/google/common/io/LittleEndianDataOutputStreamTest.java

    in.readFully(b);
    assertEquals(-100, b[0]);
    assertEquals(100, b[1]);
    assertEquals(true, in.readBoolean());
    assertEquals(false, in.readBoolean());
    assertEquals(100, in.readByte());
    assertEquals(-100, in.readByte());
    assertEquals(200, in.readUnsignedByte());
    assertEquals('\u6100', in.readChar());
    assertEquals(-12150, in.readShort());
    assertEquals(20675, in.readUnsignedShort());

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Thu Mar 12 17:47:10 GMT 2026

- 4.9K bytes

- Click Count (0)

github.com/google/guava

guava-tests/test/com/google/common/io/LittleEndianDataOutputStreamTest.java

    in.readFully(b);
    assertEquals(-100, b[0]);
    assertEquals(100, b[1]);
    assertEquals(true, in.readBoolean());
    assertEquals(false, in.readBoolean());
    assertEquals(100, in.readByte());
    assertEquals(-100, in.readByte());
    assertEquals(200, in.readUnsignedByte());
    assertEquals('\u6100', in.readChar());
    assertEquals(-12150, in.readShort());
    assertEquals(20675, in.readUnsignedShort());

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Thu Mar 12 17:47:10 GMT 2026

- 4.9K bytes

- Click Count (0)

Search Options