driver/io.github.octaviusframework.driver.io/PgOutputStream

PgOutputStream

internal class PgOutputStream(outputStream: OutputStream)

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

It provides specialized methods for efficiently writing protocol primitives like bytes, integers, shorts, and null-terminated C-style strings. Internal buffering minimizes the number of underlying network write operations.

Constructors

PgOutputStream

constructor(outputStream: OutputStream)

Functions

changeStream

fun changeStream(newStream: OutputStream)

Swaps the underlying stream, flushing what is buffered first so nothing written before the swap is lost. The read side discards instead; see PgInputStream.changeStream.

flush

fun flush()

Empties the buffer into the underlying stream and flushes that too.

writeByte

fun writeByte(b: Byte)

Buffers one byte, flushing first if the buffer is full.

writeBytes

fun writeBytes(bytes: ByteArray, offset: Int = 0, length: Int = bytes.size - offset)

Buffers length bytes of bytes starting at offset, flushing as often as it needs to.

writeCString

fun writeCString(bytes: ByteArray)

Writes a null-terminated string already encoded, for a message that needed its bytes to count its length.

fun writeCString(s: String)

Writes a null-terminated string.

writeInt

fun writeInt(i: Int)

Buffers a 32-bit integer, most significant byte first.

writeShort

fun writeShort(s: Int)

Buffers an unsigned 16-bit integer, most significant byte first - taken as an Int because the protocol's counts run to 65535 and a Short would make half of them negative.