Struct AdvReaderThread 

pub struct AdvReaderThread {

    pub source: Source,
    pub tx: Sender<Option<(usize, Result<AdvReturnValue, Error>)>>,
    pub stop: Arc<AtomicBool>,
    pub buffer_size: usize,
    pub start: Option<usize>,
    pub buffer_end: usize,
    pub line_num: usize,
    pub slash: bool,
    pub state: ReaderState,
    pub encode_comments: bool,
    pub encode_strings: bool,
    pub convert2numbers: bool,
    pub keep_base: bool,
    pub skip_comments: bool,
    pub trim: bool,
    pub bool_false: Option<Vec<u8>>,
    pub bool_true: Option<Vec<u8>>,
    pub line_end: u8,
    pub double_quote_escape: bool,
    pub extended_word_separation: bool,
    pub escape: bool,
    pub asterisk: bool,
    pub string: bool,
    pub quote: bool,
    pub block_reader: Option<Box<dyn Block + Send + Sync>>,
    pub encoding: Option<String>,
    pub encoder_errors: Option<String>,
}

Fields

source: Source

tx: Sender<Option<(usize, Result<AdvReturnValue, Error>)>>

stop: Arc<AtomicBool>

buffer_size: usize

start: Option<usize>

buffer_end: usize

line_num: usize

slash: bool

state: ReaderState

encode_comments: bool

encode_strings: bool

convert2numbers: bool

keep_base: bool

skip_comments: bool

trim: bool

bool_false: Option<Vec<u8>>

bool_true: Option<Vec<u8>>

line_end: u8

double_quote_escape: bool

extended_word_separation: bool

escape: bool

asterisk: bool

string: bool

quote: bool

block_reader: Option<Box<dyn Block + Send + Sync>>

encoding: Option<String>

encoder_errors: Option<String>

Implementations

impl AdvReaderThread

pub fn new( options: AdvReaderOptions, tx: Sender<Option<(usize, Result<AdvReturnValue, Error>)>>, stop: Arc<AtomicBool>, block_reader: Option<Box<dyn Block + Send + Sync>>, ) -> Result<Self, Error>

pub fn read_number( &mut self, itr: &mut Enumerate<Iter<'_, u8>>, i: usize, c: u8, ) -> (usize, u8, Option<AdvReturnValue>)

pub fn read_line_comment( &mut self, itr: &mut Enumerate<Iter<'_, u8>>, i: usize, c: u8, ) -> Option<(usize, u8)>

pub fn read_comment( &mut self, itr: &mut Enumerate<Iter<'_, u8>>, i: usize, c: u8, ) -> Option<(usize, u8)>

pub fn read(&mut self) -> Result<(usize, ReaderState), Error>