diff options
author | Aleksey Kladov <[email protected]> | 2018-12-30 20:23:31 +0000 |
---|---|---|
committer | Aleksey Kladov <[email protected]> | 2018-12-30 20:23:31 +0000 |
commit | c2c10b9014549e9c0783fb13dc202dfab6e6fd0a (patch) | |
tree | d4b2a47910df5effb14271ab72a1602b5f77ee81 /crates/ra_vfs/src/io.rs | |
parent | effc1eae8be338ea949058cc89c39950c25858c5 (diff) |
:arrow_up: crossbeam
closes #189
Diffstat (limited to 'crates/ra_vfs/src/io.rs')
-rw-r--r-- | crates/ra_vfs/src/io.rs | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/crates/ra_vfs/src/io.rs b/crates/ra_vfs/src/io.rs index 4cfdb83da..80328ad18 100644 --- a/crates/ra_vfs/src/io.rs +++ b/crates/ra_vfs/src/io.rs | |||
@@ -32,8 +32,10 @@ pub(crate) type Worker = thread_worker::Worker<Task, TaskResult>; | |||
32 | pub(crate) fn start() -> (Worker, WorkerHandle) { | 32 | pub(crate) fn start() -> (Worker, WorkerHandle) { |
33 | thread_worker::spawn("vfs", 128, |input_receiver, output_sender| { | 33 | thread_worker::spawn("vfs", 128, |input_receiver, output_sender| { |
34 | input_receiver | 34 | input_receiver |
35 | .into_iter() | ||
35 | .map(handle_task) | 36 | .map(handle_task) |
36 | .for_each(|it| output_sender.send(it)) | 37 | .try_for_each(|it| output_sender.send(it)) |
38 | .unwrap() | ||
37 | }) | 39 | }) |
38 | } | 40 | } |
39 | 41 | ||