Skip to main content

run_channel

Function run_channel 

Source
pub fn run_channel(
    generator: impl Stage1,
    tx_s1: Sender<SeededData<TimePoint>>,
    stats: Arc<Stats>,
) -> Result<(), Box<dyn Error>>
Expand description

Generate data and send them progressively to a channel