Skip to content
This repository has been archived by the owner on Dec 26, 2024. It is now read-only.

Commit

Permalink
refactor(network): fix cr comments
Browse files Browse the repository at this point in the history
  • Loading branch information
ShahakShama committed Jun 24, 2024
1 parent c363b23 commit bb9be89
Showing 1 changed file with 8 additions and 2 deletions.
10 changes: 8 additions & 2 deletions crates/papyrus_network/src/db_executor/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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);
}
Expand Down

0 comments on commit bb9be89

Please sign in to comment.