Robot/watchexec
1
0
Fork 0
mirror of https://github.com/watchexec/watchexec.git synced 2024-11-13 07:41:11 +01:00
Code Issues Projects Releases Packages Wiki Activity

Update to async-priority-channel 0.2.0 (#761)

Browse source
This commit is contained in:
Félix Saparelli 2024-01-04 22:13:08 +13:00 committed by GitHub
parent 682a9b4d21
commit 217f57f6a2
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
3 changed files with 5 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
Cargo.lock generated
View file

@ -230,11 +230,11 @@ dependencies = [
[[package]]
name = "async-priority-channel"
version = "0.1.0"
version = "0.2.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "c21678992e1b21bebfe2bc53ab5f5f68c106eddab31b24e0bb06e9b715a86640"
checksum = "acde96f444d31031f760c5c43dc786b97d3e1cb2ee49dd06898383fe9a999758"
dependencies = [
"event-listener 2.5.3",
"event-listener 4.0.1",
]
[[package]]

2
crates/lib/Cargo.toml
View file

@ -16,7 +16,7 @@ rust-version = "1.61.0"
edition = "2021"
[dependencies]
async-priority-channel = "0.1.0"
async-priority-channel = "0.2.0"
async-recursion = "1.0.5"
atomic-take = "1.0.0"
futures = "0.3.29"

2
crates/lib/src/watchexec.rs
View file

@ -140,7 +140,7 @@ impl Watchexec {
let notify = Arc::new(Notify::new());
let start_lock = notify.clone();
let (ev_s, ev_r) = priority::bounded(config.event_channel_size);
let (ev_s, ev_r) = priority::bounded(config.event_channel_size.try_into().unwrap_or(u64::MAX));
let event_input = ev_s.clone();
trace!("creating main task");