f new api

Author: TheBlueMatt

fuzz/src/chanmon_consistency.rs

@@ -66,7 +66,6 @@ use std::cmp::{self, Ordering};
 use hashbrown::{HashSet, hash_map, HashMap};
 use std::sync::{Arc,Mutex};
 use std::sync::atomic;
-use std::time::Duration;
 use std::io::Cursor;
 use bitcoin::bech32::u5;
 
@@ -1297,16 +1296,15 @@ pub fn do_test<Out: Output>(data: &[u8], underlying_out: Out) {
 			_ => test_return!(),
 		}
 
-		const NO_TIME: Duration = Duration::from_secs(0);
-		if nodes[0].get_event_or_persistence_needed_future().wait_timeout(NO_TIME) == Ok(true) {
+		if nodes[0].get_and_clear_needs_persistence() == Ok(true) {
 			node_a_ser.0.clear();
 			nodes[0].write(&mut node_a_ser).unwrap();
 		}
-		if nodes[1].get_event_or_persistence_needed_future().wait_timeout(NO_TIME) == Ok(true) {
+		if nodes[1].get_and_clear_needs_persistence() == Ok(true) {
 			node_b_ser.0.clear();
 			nodes[1].write(&mut node_b_ser).unwrap();
 		}
-		if nodes[2].get_event_or_persistence_needed_future().wait_timeout(NO_TIME) == Ok(true) {
+		if nodes[2].get_and_clear_needs_persistence() == Ok(true) {
 			node_c_ser.0.clear();
 			nodes[2].write(&mut node_c_ser).unwrap();
 		}