Creepso/stremio-shell-ng
1
0
Fork 0
mirror of https://github.com/Stremio/stremio-shell-ng.git synced 2026-01-11 22:40:32 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Fix race condition

Browse source
This commit is contained in:
Vladimir Borisov 2021-07-19 18:57:48 +03:00
parent fdcfceacfa
commit 5f036d2fd7
1 changed files with 7 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
src/stremio_app/stremio_wevbiew/stremio_wevbiew.rs
View file

@ -16,7 +16,7 @@ pub struct WebView {
pub channel: RefCell<Option<(mpsc::Sender<String>, Arc<Mutex<mpsc::Receiver<String>>>)>>,
notice: nwg::Notice,
compute: RefCell<Option<thread::JoinHandle<()>>>,
message: Arc<Mutex<Option<String>>>,
message: Arc<Mutex<Vec<String>>>,
}
impl WebView {
@ -112,7 +112,7 @@ impl PartialUi for WebView {
*data.compute.borrow_mut() = Some(thread::spawn(move || loop {
if let Ok(msg) = rx.try_recv() {
let mut message = message.lock().unwrap();
*message = Some(msg);
message.push(msg);
sender.notice();
}
}));
@ -138,14 +138,14 @@ impl PartialUi for WebView {
}
E::OnNotice => {
let msg = self.message.clone();
let mut msg = msg.lock().unwrap();
if let Some(msg) = &*msg {
if let Some(controller) = self.controller.get() {
let webview = controller.get_webview().expect("Cannot get vebview");
if let Some(controller) = self.controller.get() {
let webview = controller.get_webview().expect("Cannot get vebview");
let mut msg = msg.lock().unwrap();
for msg in msg.iter() {
webview.post_web_message_as_string(msg).ok();
}
*msg = vec![];
}
*msg = None;
}
_ => {}
}