Enum ReaderState 

enum ReaderState<R> {
    InvalidState,
    Idle {
        reader: R,
    },
    FetchingData {
        future: BoxFuture<'static, Result<(R, Bytes), AvroError>>,
        next_behaviour: FetchNextBehaviour,
    },
    DecodingBlock {
        data: Bytes,
        reader: R,
    },
    ReadingBatches {
        data: Bytes,
        block_data: Bytes,
        remaining_in_block: usize,
        reader: R,
    },
    Flushing,
    Finished,
}

Variants

InvalidState

Intermediate state to fix ownership issues

Idle

Initial state, fetch initial range

Fields

reader: R

FetchingData

Fetching data from the reader

Fields

future: BoxFuture<'static, Result<(R, Bytes), AvroError>>

next_behaviour: FetchNextBehaviour

DecodingBlock

Decode a block in a loop until completion

Fields

data: Bytes

reader: R

ReadingBatches

Output batches from a decoded block

Fields

data: Bytes

block_data: Bytes

remaining_in_block: usize

reader: R

Flushing

Successfully finished reading file contents; drain any remaining buffered records from the decoder into (possibly partial) output batches.

Finished

Done, flush decoder and return