0.5.1

core/gay.zharel.fateweaver.log/FateLogReader

FateLogReader

class FateLogReader(stream: InputStream) : AutoCloseable, Iterator<FateLogEntry>

Reads logs written by FateLogWriter, one entry at a time.

Constructors

constructor(stream: InputStream)

Types

data class ChannelInfo(val name: String, val schema: FateSchema<*>)

object Companion

Functions

open override fun close()

fun getChannel(index: Int): FateLogReader.ChannelInfo?

Returns the channel at index, or null if its schema entry hasn't been read.

fun getChannels(): List<FateLogReader.ChannelInfo>

Returns the channels whose schema entries have been read so far.

open operator override fun hasNext(): Boolean

open operator override fun next(): FateLogEntry

fun readAll(): List<FateLogEntry>

Reads every remaining entry into a list. This consumes the reader.

readMessagesForChannel

fun readMessagesForChannel(channelName: String): List<FateLogEntry.Message<*>>

Reads every remaining entry and returns the messages for channelName.