mikros/rust
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Use the send method

Browse Source
This commit is contained in:
mo8it 2024-08-12 10:55:04 +02:00
parent 285285d3fd
commit f7c4716dbf
1 changed files with 23 additions and 31 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
src/tools/rust-analyzer/crates/vfs-notify/src/lib.rs
View File

@ -119,14 +119,12 @@ fn run(mut self, inbox: Receiver<Message>) {
self.watched_dir_entries.clear();
self.watched_file_entries.clear();
self.sender
.send(loader::Message::Progress {
self.send(loader::Message::Progress {
n_total,
n_done: LoadingProgress::Started,
config_version,
dir: None,
})
.unwrap();
});
let (entry_tx, entry_rx) = unbounded();
let (watch_tx, watch_rx) = unbounded();
@ -142,31 +140,25 @@ fn run(mut self, inbox: Receiver<Message>) {
entry,
do_watch,
|file| {
self.sender
.send(loader::Message::Progress {
self.send(loader::Message::Progress {
n_total,
n_done: LoadingProgress::Progress(
processed
.load(std::sync::atomic::Ordering::Relaxed),
processed.load(std::sync::atomic::Ordering::Relaxed),
),
dir: Some(file),
config_version,
})
.unwrap()
});
},
);
self.sender.send(loader::Message::Loaded { files }).unwrap();
self.sender
.send(loader::Message::Progress {
self.send(loader::Message::Loaded { files });
self.send(loader::Message::Progress {
n_total,
n_done: LoadingProgress::Progress(
processed.fetch_add(1, std::sync::atomic::Ordering::AcqRel)
+ 1,
processed.fetch_add(1, std::sync::atomic::Ordering::AcqRel) + 1,
),
config_version,
dir: None,
})
.unwrap();
});
});
drop(watch_tx);