Function alice_protocol_reader::spawn_reader

source ·

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