refactor: update dependencies
This commit is contained in:
parent
16caa1e034
commit
831a30ac53
File diff suppressed because it is too large
Load Diff
|
@ -1,5 +1,3 @@
|
||||||
cargo-features = ["edition"]
|
|
||||||
|
|
||||||
[package]
|
[package]
|
||||||
name = "screenshot_organiser"
|
name = "screenshot_organiser"
|
||||||
version = "0.1.0"
|
version = "0.1.0"
|
||||||
|
@ -11,7 +9,7 @@ edition = "2018"
|
||||||
chrono = "0.4"
|
chrono = "0.4"
|
||||||
regex = "1"
|
regex = "1"
|
||||||
notify = "4"
|
notify = "4"
|
||||||
image = "0.19"
|
image = "0.20"
|
||||||
serde = "1"
|
serde = "1"
|
||||||
serde_derive = "1"
|
serde_derive = "1"
|
||||||
serde_json = "1"
|
serde_json = "1"
|
||||||
|
@ -21,4 +19,4 @@ tempdir = "0.3"
|
||||||
num_cpus = "1"
|
num_cpus = "1"
|
||||||
rayon = "1"
|
rayon = "1"
|
||||||
ctrlc = "3"
|
ctrlc = "3"
|
||||||
crossbeam-channel = "0.2"
|
crossbeam-channel = "0.3"
|
||||||
|
|
24
src/main.rs
24
src/main.rs
|
@ -1,5 +1,3 @@
|
||||||
#![feature(rust_2018_preview, iterator_find_map, use_extern_macros)]
|
|
||||||
|
|
||||||
#[macro_use] extern crate crossbeam_channel;
|
#[macro_use] extern crate crossbeam_channel;
|
||||||
#[macro_use] extern crate serde_derive;
|
#[macro_use] extern crate serde_derive;
|
||||||
|
|
||||||
|
@ -70,7 +68,7 @@ fn main() -> Result<()> {
|
||||||
|
|
||||||
watcher.watch(
|
watcher.watch(
|
||||||
screenshots_dir.to_string_lossy().to_string(),
|
screenshots_dir.to_string_lossy().to_string(),
|
||||||
RecursiveMode::NonRecursive
|
RecursiveMode::NonRecursive,
|
||||||
)?;
|
)?;
|
||||||
|
|
||||||
{
|
{
|
||||||
|
@ -79,12 +77,12 @@ fn main() -> Result<()> {
|
||||||
let tick = crossbeam_channel::tick(Duration::milliseconds(50).to_std().unwrap());
|
let tick = crossbeam_channel::tick(Duration::milliseconds(50).to_std().unwrap());
|
||||||
loop {
|
loop {
|
||||||
select! {
|
select! {
|
||||||
recv(tick, _) => match rx.try_recv() {
|
recv(tick) -> _ => match rx.try_recv() {
|
||||||
Ok(e) => event_tx.send(e),
|
Ok(e) => { event_tx.send(e).ok(); },
|
||||||
Err(TryRecvError::Empty) => {},
|
Err(TryRecvError::Empty) => {},
|
||||||
Err(TryRecvError::Disconnected) => break,
|
Err(TryRecvError::Disconnected) => break,
|
||||||
},
|
},
|
||||||
recv(thread_ctrlc_rx, _) => break,
|
recv(thread_ctrlc_rx) -> _ => break,
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}));
|
}));
|
||||||
|
@ -103,14 +101,14 @@ fn main() -> Result<()> {
|
||||||
let handle = std::thread::spawn(move || {
|
let handle = std::thread::spawn(move || {
|
||||||
loop {
|
loop {
|
||||||
select! {
|
select! {
|
||||||
recv(thread_ctrlc_rx, _) => break,
|
recv(thread_ctrlc_rx) -> _ => break,
|
||||||
recv(thread_event_rx, e) => {
|
recv(thread_event_rx) -> event => {
|
||||||
match e {
|
match event {
|
||||||
Some(DebouncedEvent::Create(p)) => if let Err(e) = handle(&thread_config, Some(i), temp_path.clone(), p) {
|
Ok(DebouncedEvent::Create(p)) => if let Err(e) = handle(&thread_config, Some(i), temp_path.clone(), p) {
|
||||||
eprintln!("{}", e);
|
eprintln!("{}", e);
|
||||||
},
|
},
|
||||||
Some(_) => {},
|
Ok(_) => {},
|
||||||
None => eprintln!("{:#?}", e),
|
Err(e) => eprintln!("{:#?}", e),
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
}
|
}
|
||||||
|
@ -206,7 +204,7 @@ fn set_ctrlc_handler(num_threads: usize) -> Result<Receiver<()>> {
|
||||||
ctrlc::set_handler(move || {
|
ctrlc::set_handler(move || {
|
||||||
println!("Received interrupt.");
|
println!("Received interrupt.");
|
||||||
for _ in 0..num_threads {
|
for _ in 0..num_threads {
|
||||||
tx.send(());
|
tx.send(()).ok();
|
||||||
}
|
}
|
||||||
})?;
|
})?;
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue