Merge pull request #270 from rustaceanrob/async-event-1-14

Remove async from `send_event`

Author: rustaceanrob

src/chain/chain.rs

@@ -460,9 +460,7 @@ impl<H: HeaderStore> Chain<H> {
                 self.cf_header_chain.remove(removed_hashes);
                 self.filter_chain.remove(removed_hashes);
                 self.block_queue.remove(removed_hashes);
-                self.dialog
-                    .send_event(Event::BlocksDisconnected(reorged))
-                    .await;
+                self.dialog.send_event(Event::BlocksDisconnected(reorged));
                 self.flush_over_height(stem).await;
                 Ok(())
             } else {
@@ -747,9 +745,7 @@ impl<H: HeaderStore> Chain<H> {
                 .await
                 .ok_or(CFilterSyncError::UnknownFilterHash)?;
             let indexed_filter = IndexedFilter::new(height, filter);
-            self.dialog
-                .send_event(Event::IndexedFilter(indexed_filter))
-                .await;
+            self.dialog.send_event(Event::IndexedFilter(indexed_filter));
         }
 
         #[cfg(not(feature = "filter-control"))]
@@ -845,8 +841,7 @@ impl<H: HeaderStore> Chain<H> {
             }
             None => {
                 self.dialog
-                    .send_event(Event::Block(IndexedBlock::new(height, block)))
-                    .await;
+                    .send_event(Event::Block(IndexedBlock::new(height, block)));
             }
         }
         Ok(())

src/core/dialog.rs

@@ -56,7 +56,7 @@ impl Dialog {
         let _ = self.log_tx.send(info).await;
     }
 
-    pub(crate) async fn send_event(&self, message: Event) {
+    pub(crate) fn send_event(&self, message: Event) {
         let _ = self.event_tx.send(message);
     }
 }

src/core/node.rs

@@ -466,7 +466,7 @@ impl<H: HeaderStore, P: PeerStore> Node<H, P> {
                     self.dialog
                         .send_info(Log::StateChange(NodeState::TransactionsSynced))
                         .await;
-                    let _ = self.dialog.send_event(Event::Synced(update)).await;
+                    self.dialog.send_event(Event::Synced(update));
                 }
             }
             NodeState::TransactionsSynced => {