perf: use a blocking task to process transmission responses in the wo…

…rker

Signed-off-by: ljedrz <ljedrz@gmail.com>

node/bft/src/worker.rs

@@ -376,7 +376,15 @@ impl<N: Network> Worker<N> {
         self.spawn(async move {
             while let Some((peer_ip, transmission_response)) = rx_transmission_response.recv().await {
                 // Process the transmission response.
-                self_.finish_transmission_request(peer_ip, transmission_response);
+                let self__ = self_.clone();
+                if tokio::task::spawn_blocking(move || {
+                    self__.finish_transmission_request(peer_ip, transmission_response);
+                })
+                .await
+                .is_err()
+                {
+                    error!("Failed to await on Worker::finish_transmission_request");
+                }
             }
         });
     }