diff options
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 | ||