driver/io.github.octaviusframework.driver.io/PgInputStream

PgInputStream

internal class PgInputStream(inputStream: InputStream)

A highly optimized, buffered input stream tailored for the PostgreSQL wire protocol.

It provides specialized methods for efficiently reading protocol primitives like bytes, integers, shorts, and null-terminated C-style strings. Internal buffering is used to minimize network reads and object allocations.

Constructors

PgInputStream

constructor(inputStream: InputStream)

Functions

changeStream

fun changeStream(newStream: InputStream)

readByte

fun readByte(): Byte

readBytes

fun readBytes(length: Int): ByteArray

Returns exactly the specified number of bytes.

readCString

fun readCString(): String

Reads a null-terminated string.

readFully

fun readFully(bytes: ByteArray, length: Int = bytes.size)

readInt

fun readInt(): Int

readShort

fun readShort(): Short

skip

fun skip(length: Int)

Advances past exactly length bytes without materializing them.