MultiSink

Sends every entry to each of sinks, in order.

Use it to record to a file and broadcast to live readers from one FateLogWriter.

Constructors

constructor(vararg sinks: FateSink)

constructor(sinks: List<FateSink>)

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