diff --git a/src/event.rs b/src/event.rs index 329ca6abc..0b84baf72 100644 --- a/src/event.rs +++ b/src/event.rs @@ -834,8 +834,8 @@ mod tests { use super::*; use lightning::util::test_utils::{TestLogger, TestStore}; - #[test] - fn event_queue_persistence() { + #[tokio::test] + async fn event_queue_persistence() { let store = Arc::new(TestStore::new(false)); let logger = Arc::new(TestLogger::new()); let event_queue = EventQueue::new(Arc::clone(&store), Arc::clone(&logger)); @@ -851,6 +851,7 @@ mod tests { // Check we get the expected event and that it is returned until we mark it handled. for _ in 0..5 { assert_eq!(event_queue.wait_next_event(), expected_event); + assert_eq!(event_queue.next_event_async().await, expected_event); assert_eq!(event_queue.next_event(), Some(expected_event.clone())); }