Searched refs:subscribe (Results 1 – 9 of 9) sorted by relevance
33 pub fn subscribe() -> Receiver<Event> { in subscribe() function34 get_events().lock().expect("Failed to acquire locks on events").subscribe() in subscribe()123 fn subscribe(&mut self) -> Receiver<Event> { in subscribe() method155 pub fn subscribe(s: &mut Arc<Mutex<Events>>) -> Receiver<Event> { in subscribe() function156 s.lock().unwrap().subscribe() in subscribe()172 let rx = events_clone.lock().unwrap().subscribe(); in test_subscribe_and_publish()199 let rx = events_clone.lock().unwrap().subscribe(); in test_publish_to_multiple_subscribers()228 let rx = events.lock().unwrap().subscribe(); in test_publish_to_dropped_subscriber()
271 let capture_events_rx = events::subscribe(); in run_netsimd_primary()272 let device_events_rx = events::subscribe(); in run_netsimd_primary()273 let main_events_rx = events::subscribe(); in run_netsimd_primary()274 let session_events_rx = events::subscribe(); in run_netsimd_primary()
231 let events_rx = events::test::subscribe(&mut events); in setup_session_start_test()
23 from acts.event.decorators import subscribe306 @subscribe(TestCaseBeginEvent)311 @subscribe(TestCaseEndEvent)316 @subscribe(TestClassEndEvent)335 @subscribe(TestClassBeginEvent)340 @subscribe(TestClassEndEvent)
22 from acts.event.decorators import subscribe56 @subscribe(type)119 @subscribe(DummyEvent)
21 from acts.event.decorators import subscribe147 @subscribe(Event)151 @subscribe(Event)
24 from acts.event.decorators import subscribe, subscribe_static39 @subscribe(Event)
35 def subscribe(event_type, event_filter=None, order=0): function
684 let event_rx = events::subscribe(); in handle_device_subscribe()984 let events_rx = events::test::subscribe(&mut events); in spawn_shutdown_publisher_test_setup()987 let events_rx2 = events::test::subscribe(&mut events); in spawn_shutdown_publisher_test_setup()1699 let events_rx = events::test::subscribe(&mut events); in test_check_device_event_initial_timeout()1711 let events_rx = events::test::subscribe(&mut events); in test_check_device_event_last_device_removed()1727 let events_rx = events::test::subscribe(&mut events); in test_check_device_event_device_chip_added()1749 let events_rx = events::test::subscribe(&mut events); in test_check_device_event_ignore_event()1770 let events_rx = events::test::subscribe(&mut events); in test_check_device_event_ignore_chip_added_for_builtin()