aboutsummaryrefslogtreecommitdiff
path: root/client-native-lib/src
diff options
context:
space:
mode:
authormetamuffin <metamuffin@disroot.org>2024-03-18 22:08:38 +0100
committermetamuffin <metamuffin@disroot.org>2024-03-18 22:08:38 +0100
commit3cd6a4947407920726e60a9d29c37f7d40fda545 (patch)
tree85e5e69963f1aa8abfba30e6791fba65f258ecec /client-native-lib/src
parent5370e79e69771976e27079f4a9fffe807efabd83 (diff)
downloadkeks-meet-3cd6a4947407920726e60a9d29c37f7d40fda545.tar
keks-meet-3cd6a4947407920726e60a9d29c37f7d40fda545.tar.bz2
keks-meet-3cd6a4947407920726e60a9d29c37f7d40fda545.tar.zst
rift: refactor code
Diffstat (limited to 'client-native-lib/src')
-rw-r--r--client-native-lib/src/instance.rs14
1 files changed, 9 insertions, 5 deletions
diff --git a/client-native-lib/src/instance.rs b/client-native-lib/src/instance.rs
index 899e48c..476d9bd 100644
--- a/client-native-lib/src/instance.rs
+++ b/client-native-lib/src/instance.rs
@@ -181,11 +181,15 @@ impl Instance {
.await
.insert(res.info().id, res);
}
- pub async fn remove_local_resource(&self, id: String) {
- self.local_resources.write().await.remove(&id);
- for (_pid, peer) in self.peers.read().await.iter() {
- peer.send_relay(RelayMessage::ProvideStop { id: id.clone() })
- .await;
+ pub async fn remove_local_resource(&self, id: String) -> bool {
+ if let Some(_) = self.local_resources.write().await.remove(&id) {
+ for (_pid, peer) in self.peers.read().await.iter() {
+ peer.send_relay(RelayMessage::ProvideStop { id: id.clone() })
+ .await;
+ }
+ true
+ } else {
+ false
}
}
}