Searched defs:rx1 (Results 1 – 4 of 4) sorted by relevance
88 let rx1 = Box::pin(rx1); in multiple_entries() localVariable177 let rx1 = Box::pin(rx1); in replace() localVariable
83 let rx1 = notify.clone(); in notify_drop() localVariable
96 let mut rx1 = rx1.fuse(); in select_streams() localVariable147 let mut rx1 = rx1.fuse(); in select_can_move_uncompleted_futures() localVariable
437 let rx1 = RX1.load(SeqCst); in local_tasks_are_polled_after_tick() localVariable