refactor: multithreaded mining

1 files changed, 6 insertions, 4 deletions

diff --git a/src/network.rs b/src/network.rs
index 8ca5ab0..1708d2e 100644
--- a/src/network.rs
+++ b/src/network.rs
@@ -169,14 +169,14 @@ impl Network {
                 .clone()
         };
         for p in peers {
-            p.lock()
+            _ = p
+                .lock()
                 .await
                 .sink
                 .lock()
                 .await
                 .send(data.clone())
-                .await
-                .unwrap();
+                .await;
         }
     }
 
@@ -262,7 +262,9 @@ impl Peer {
                         .store(block)
                 } else {
                     println!("Mining new block for transaction: {:#?}", block.trans);
-                    block.calc_set_pow();
+                    block
+                        .calc_set_pow()
+                        .await;
                     let network = parent
                         .upgrade()
                         .unwrap();