Skip to main content

new_candidate_channel_list

mito2::read::series_scan

Function new_candidate_channel_list 

Source 
fn new_candidate_channel_list(
    num_partitions: usize,
) -> (Vec<Option<UnboundedSender<Result<SeriesReaderInput>>>>, Vec<Option<CandidateReceiver>>, Arc<AtomicUsize>)