fn handle_results(
tx: &UnboundedSender<ReplyBatch>,
rx_f: Arc<AtomicBool>,
worker_id: u16,
reply_rx: Receiver<Reply>,
origin_id: u32,
)Expand description
Forward results to the Worker handler
ยงArguments
tx- sender to put task results inrx_f- channel that is used to signal the end of the measurementworker_id- the unique worker ID of this workerreply_rx- channel receiver for replies from the listener threadorigin_id- origin ID associated with this inbound handler