From c475832acfba8cd8218d7a5cddc5b8b159833250 Mon Sep 17 00:00:00 2001
From: Arindam Singh <98768062+Arindam2407@users.noreply.github.com>
Date: Wed, 15 Nov 2023 04:38:13 +0000
Subject: [PATCH] Update mod.rs

---
 crates/primitives/src/transaction/mod.rs | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/crates/primitives/src/transaction/mod.rs b/crates/primitives/src/transaction/mod.rs
index e744002040c0..67220c5d3443 100644
--- a/crates/primitives/src/transaction/mod.rs
+++ b/crates/primitives/src/transaction/mod.rs
@@ -11,7 +11,7 @@ use once_cell::sync::Lazy;
 use rayon::prelude::*;
 use reth_codecs::{add_arbitrary_tests, derive_arbitrary, Compact};
 use serde::{Deserialize, Serialize};
-use std::{mem, thread, sync::mpsc};
+use std::{mem, sync::mpsc, thread};
 
 pub use access_list::{AccessList, AccessListItem};
 pub use eip1559::TxEip1559;
@@ -879,8 +879,8 @@ impl TransactionSignedNoHash {
                 })
             });
             thread::spawn(move || {
-                for mut channel in channels {
-                    while let Some(recovered) = channel.blocking_recv() {
+                for channel in channels {
+                    while let Ok(recovered) = channel.recv() {
                         match recovered {
                             Some(signer) => {
                                 recovered_signers.push(signer);
@@ -1079,8 +1079,8 @@ impl TransactionSigned {
                 })
             });
             thread::spawn(move || {
-                for mut channel in channels {
-                    while let Some(recovered) = channel.blocking_recv() {
+                for channel in channels {
+                    while let Ok(recovered) = channel.recv() {
                         match recovered {
                             Some(signer) => {
                                 recovered_signers.push(signer);