Searched defs:rx1 (Results 1 – 6 of 6) sorted by relevance
88 let rx1 = Box::pin(rx1); in multiple_entries() localVariable177 let rx1 = Box::pin(rx1); in replace() localVariable
111 regex rx1("a([0-9]+)c"); in replace_test() local
82 let mut rx1 = rx1.fuse(); in select_streams() localVariable128 let mut rx1 = rx1.fuse(); in select_can_move_uncompleted_futures() localVariable
66 rule<> rx1; in rule_template_param_tests() local
117 let rx1 = notify.clone(); in notify_drop() localVariable
508 let rx1 = RX1.load(SeqCst); in local_tasks_are_polled_after_tick_inner() localVariable