Skip to content

Commit

Permalink
fix: bounded channel
Browse files Browse the repository at this point in the history
  • Loading branch information
Ludo Galabru committed Nov 28, 2023
1 parent 8253524 commit 6d7de20
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@ use chainhook_sdk::{
},
utils::Context,
};
use crossbeam_channel::bounded;
use crossbeam_channel::unbounded;
use dashmap::DashMap;
use fxhash::FxHasher;
use rusqlite::{Connection, Transaction};
Expand Down Expand Up @@ -98,7 +98,7 @@ pub fn parallelize_inscription_data_computations(
}

let expected_traversals = transactions_ids.len() + l1_cache_hits.len();
let (traversal_tx, traversal_rx) = bounded(64);
let (traversal_tx, traversal_rx) = unbounded();

let mut tx_thread_pool = vec![];
let mut thread_pool_handles = vec![];
Expand Down

0 comments on commit 6d7de20

Please sign in to comment.