0.5.1

core/gay.zharel.fateweaver.log/StreamSink

StreamSink

class StreamSink(val stream: OutputStream) : FateSink

Writes every entry to stream as is, whatever its kind.

FateLogWriter's OutputStream constructor wraps a stream in one of these.

Constructors

constructor(stream: OutputStream)

Properties

val stream: OutputStream

Functions

open override fun close()

open override fun flush()

Pushes anything buffered onward.

open override fun header(bytes: ByteArray)

The 4-byte magic and version that open a log.

open override fun messageEntry(bytes: ByteArray)

A complete message entry (kind 1). It carries one value for an already declared channel.

open override fun schemaEntry(bytes: ByteArray)

A complete schema entry (kind 0). It declares the channel at the next index.

open override fun toString(): String