Skip to content

Commit e27b65a

Browse files
committed
replace flume with crossbeam-channel as it's already in the dependency graph (#470)
1 parent e3e3211 commit e27b65a

File tree

3 files changed

+5
-57
lines changed

3 files changed

+5
-57
lines changed

Cargo.lock

+1-54
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

gitoxide-core/Cargo.toml

+2-2
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@ default = []
1818
## Discover all git repositories within a directory. Particularly useful with [skim](https://github.com/lotabout/skim).
1919
organize = ["git-url", "jwalk"]
2020
## Derive the amount of time invested into a git repository akin to [git-hours](https://github.com/kimmobrunfeldt/git-hours).
21-
estimate-hours = ["itertools", "fs-err", "num_cpus", "flume"]
21+
estimate-hours = ["itertools", "fs-err", "num_cpus", "crossbeam-channel"]
2222

2323
#! ### Mutually Exclusive Networking
2424
#! 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 }
6363
itertools = { version = "0.10.1", optional = true }
6464
fs-err = { version = "2.6.0", optional = true }
6565
num_cpus = { version = "1.13.1", optional = true }
66-
flume = { version = "0.10.14", optional = true }
66+
crossbeam-channel = { version = "0.5.6", optional = true }
6767

6868
document-features = { version = "0.2.0", optional = true }
6969

gitoxide-core/src/hours.rs

+2-1
Original file line numberDiff line numberDiff line change
@@ -132,7 +132,8 @@ where
132132
let (tx_tree_id, stat_threads) = needs_stats
133133
.then(|| {
134134
let num_threads = num_cpus::get().saturating_sub(1 /*main thread*/).max(1);
135-
let (tx, rx) = flume::unbounded::<(u32, Option<git::hash::ObjectId>, git::hash::ObjectId)>();
135+
let (tx, rx) =
136+
crossbeam_channel::unbounded::<(u32, Option<git::hash::ObjectId>, git::hash::ObjectId)>();
136137
let stat_workers = (0..num_threads)
137138
.map(|_| {
138139
scope.spawn({

0 commit comments

Comments
 (0)