Enum ReadOutput

pub enum ReadOutput {
    Batch(SequencedRecordBatch),
    NextSeqNum(u64),
}

Batch of records or the next sequence number on the stream.

Variants

Batch(SequencedRecordBatch)

Batch of records. It can only be empty outside of a session context, if the request cannot be satisfied without violating its limit.

NextSeqNum(u64)

Tail of the stream, i.e. sequence number that will be assigned to the next record. It will primarily be returned either because the requested starting point was larger, or only in case of a limited read, equal to the tail. It will also be returned if there are no records on the stream between the requested starting point and the tail.

Trait Implementations

impl Clone for ReadOutput

fn clone(&self) -> ReadOutput

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ReadOutput

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.