diff --git a/src/ndb.rs b/src/ndb.rs index 407fb8a..8294af8 100644 --- a/src/ndb.rs +++ b/src/ndb.rs @@ -159,7 +159,11 @@ impl Ndb { vec.into_iter().map(NoteKey::new).collect() } - pub async fn wait_for_notes(&self, sub_id: Subscription, max_notes: u32) -> Result> { + pub async fn wait_for_notes( + &self, + sub_id: Subscription, + max_notes: u32, + ) -> Result> { let ndb = self.clone(); let handle = task::spawn_blocking(move || { let mut vec: Vec = vec![]; diff --git a/src/subscription.rs b/src/subscription.rs index 98d90fa..8e77d6a 100644 --- a/src/subscription.rs +++ b/src/subscription.rs @@ -1,4 +1,3 @@ - #[derive(Debug, Clone, Copy, Eq, PartialEq)] pub struct Subscription(u64);