pub fn spawn_reader<T: RDH + 'static, const CAP: usize>(
stop_flag: Arc<AtomicBool>,
input_scanner: InputScanner<impl BufferedReaderWrapper + ?Sized + 'static>,
) -> (JoinHandle<()>, Receiver<CdpArray<T, CAP>>)Expand description
Spawns a reader thread that reads CDPs from the input and sends them to a producer channel
Returns the thread handle and the receiver channel
If you want more control of the batch size at runtime, use spawn_vec_reader instead.