Struct TypedChunkReader

Defined in File reader.hpp

Struct Documentation

struct TypedChunkReader

Public Functions

TypedChunkReader()

TypedChunkReader(const TypedChunkReader&) = delete

TypedChunkReader &operator=(const TypedChunkReader&) = delete

TypedChunkReader(TypedChunkReader&&) = delete

TypedChunkReader &operator=(TypedChunkReader&&) = delete

void reset(const Chunk &chunk, Compression compression)

bool next()

ByteOffset offset() const

const Status &status() const

Public Members

std::function<void(const SchemaPtr, ByteOffset)> onSchema

std::function<void(const ChannelPtr, ByteOffset)> onChannel

std::function<void(const Message&, ByteOffset)> onMessage

std::function<void(const Record&, ByteOffset)> onUnknownRecord