replace flume with crossbeam-channel as it's already in the depen…

…dency graph (#470)
GitoxideLabs · Sep 20, 2022 · e27b65a · e27b65a
1 parent e3e3211
commit e27b65a
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 57 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/gitoxide-core/Cargo.toml b/gitoxide-core/Cargo.toml
@@ -18,7 +18,7 @@ default = []
 ## Discover all git repositories within a directory. Particularly useful with [skim](https://github.com/lotabout/skim).
 organize = ["git-url", "jwalk"]
 ## Derive the amount of time invested into a git repository akin to [git-hours](https://github.com/kimmobrunfeldt/git-hours).
-estimate-hours = ["itertools", "fs-err", "num_cpus", "flume"]
+estimate-hours = ["itertools", "fs-err", "num_cpus", "crossbeam-channel"]
 
 #! ### Mutually Exclusive Networking
 #! If both are set, _blocking-client_ will take precedence, allowing `--all-features` to be used.
@@ -63,7 +63,7 @@ jwalk = { version = "0.6.0", optional = true }
 itertools = { version = "0.10.1", optional = true }
 fs-err = { version = "2.6.0", optional = true }
 num_cpus = { version = "1.13.1", optional = true }
-flume = { version = "0.10.14", optional = true }
+crossbeam-channel = { version = "0.5.6", optional = true }
 
 document-features = { version = "0.2.0", optional = true }
 

diff --git a/gitoxide-core/src/hours.rs b/gitoxide-core/src/hours.rs
@@ -132,7 +132,8 @@ where
             let (tx_tree_id, stat_threads) = needs_stats
                 .then(|| {
                     let num_threads = num_cpus::get().saturating_sub(1 /*main thread*/).max(1);
-                    let (tx, rx) = flume::unbounded::<(u32, Option<git::hash::ObjectId>, git::hash::ObjectId)>();
+                    let (tx, rx) =
+                        crossbeam_channel::unbounded::<(u32, Option<git::hash::ObjectId>, git::hash::ObjectId)>();
                     let stat_workers = (0..num_threads)
                         .map(|_| {
                             scope.spawn({