Merge pull request #244 from rustaceanrob/filter-12-18

Remove unnecessary `async` from `Filter::contains_any`

example/managed.rs

@@ -63,7 +63,7 @@ async fn main() {
                     tracing::info!("Connected to all required peers");
                 }
                 NodeMessage::IndexedFilter(mut filter) => {
-                    if filter.contains_any(&addresses).await {
+                    if filter.contains_any(&addresses) {
                         let hash = *filter.block_hash();
                         tracing::info!("Found script at {}!", hash);
                         let indexed_block = client.get_block(hash).await.unwrap();

src/chain/chain.rs

@@ -768,7 +768,6 @@ impl<H: HeaderStore> Chain<H> {
         if !self.block_queue.contains(&filter_message.block_hash)
             && filter
                 .contains_any(&self.scripts)
-                .await
                 .map_err(CFilterSyncError::Filter)?
         {
             // Add to the block queue

src/filters/mod.rs

@@ -42,10 +42,7 @@ impl Filter {
         &self.block_hash
     }
 
-    pub async fn contains_any(
-        &mut self,
-        scripts: &HashSet<ScriptBuf>,
-    ) -> Result<bool, FilterError> {
+    pub fn contains_any(&mut self, scripts: &HashSet<ScriptBuf>) -> Result<bool, FilterError> {
         self.block_filter
             .match_any(
                 &self.block_hash,

src/lib.rs

@@ -205,10 +205,9 @@ impl IndexedFilter {
     }
 
     /// Does the filter contain a positive match for any of the provided scripts
-    pub async fn contains_any(&mut self, scripts: &HashSet<ScriptBuf>) -> bool {
+    pub fn contains_any(&mut self, scripts: &HashSet<ScriptBuf>) -> bool {
         self.filter
             .contains_any(scripts)
-            .await
             .expect("vec reader is infallible")
     }
 }