From bb9be89650b06da318187ea28086da5bdbfce408 Mon Sep 17 00:00:00 2001 From: Shahak Shama Date: Thu, 20 Jun 2024 11:49:15 +0300 Subject: [PATCH] refactor(network): fix cr comments --- crates/papyrus_network/src/db_executor/mod.rs | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/crates/papyrus_network/src/db_executor/mod.rs b/crates/papyrus_network/src/db_executor/mod.rs index 66f9b17b51..4151ff8644 100644 --- a/crates/papyrus_network/src/db_executor/mod.rs +++ b/crates/papyrus_network/src/db_executor/mod.rs @@ -120,13 +120,19 @@ impl DBExecutorTrait for DBExecutor { }; tokio::select! { - Some((query_result, response_sender)) = header_queries_receiver_future => { + result = header_queries_receiver_future => { + let (query_result, response_sender) = result.expect( + "Header queries sender was unexpectedly dropped." + ); // TODO(shahak): Report if query_result is Err. if let Ok(query) = query_result { self.register_query(query.0, response_sender); } } - Some((query_result, response_sender)) = state_diff_queries_receiver_future => { + result = state_diff_queries_receiver_future => { + let (query_result, response_sender) = result.expect( + "State diff queries sender was unexpectedly dropped." + ); if let Ok(query) = query_result { self.register_query(query.0, response_sender); }