Searched refs:rx_source (Results 1 – 1 of 1) sorted by relevance
1173 let rx_source = ex.register_source(&rx).expect("register source failed"); in canceled_before_completion() localVariable1176 let read_task = rx_source in canceled_before_completion()