pub fn spawn_vec_reader<T: RDH + 'static>(
stop_flag: Arc<AtomicBool>,
input_scanner: InputScanner<impl BufferedReaderWrapper + ?Sized + 'static>,
) -> (JoinHandle<()>, Receiver<CdpVec<T>>)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