diff options
author | Manos Pitsidianakis <el13635@mail.ntua.gr> | 2019-06-18 21:13:58 +0300 |
---|---|---|
committer | Manos Pitsidianakis <el13635@mail.ntua.gr> | 2019-06-18 21:14:14 +0300 |
commit | 24831b3c13c351418d990e9c8ea94bbece223d97 (patch) | |
tree | ee92edf8271af8e7f837bddff6037d2bb45451aa /ui/src/workers.rs | |
parent | a51a164711bab2dc116d089fa494baf7013b2a98 (diff) |
Fix warnings, lints, and 2018 errors
Diffstat (limited to 'ui/src/workers.rs')
-rw-r--r-- | ui/src/workers.rs | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/ui/src/workers.rs b/ui/src/workers.rs index 6532ed7d..7279f49d 100644 --- a/ui/src/workers.rs +++ b/ui/src/workers.rs @@ -152,7 +152,7 @@ impl<T: Send> WorkQueue<T> { impl WorkController { pub fn new() -> WorkController { - let (new_jobs_tx, new_jobs_rx) = chan::async(); + let (new_jobs_tx, new_jobs_rx) = chan::r#async(); // Create a new work queue to keep track of what work needs to be done. // Note that the queue is internally mutable (or, rather, the Mutex is), // but this binding doesn't need to be mutable. This isn't unsound because @@ -163,7 +163,7 @@ impl WorkController { // Create a MPSC (Multiple Producer, Single Consumer) channel. Every worker // is a producer, the main thread is a consumer; the producers put their // work into the channel when it's done. - let (results_tx, results_rx) = chan::async(); + let (results_tx, results_rx) = chan::r#async(); // Create a SyncFlag to share whether or not there are more jobs to be done. let (thread_end_tx, thread_end_rx) = chan::sync(::std::mem::size_of::<bool>()); |