From 3cd6a4947407920726e60a9d29c37f7d40fda545 Mon Sep 17 00:00:00 2001 From: metamuffin Date: Mon, 18 Mar 2024 22:08:38 +0100 Subject: rift: refactor code --- client-native-lib/Cargo.toml | 2 +- client-native-lib/src/instance.rs | 14 +++++++++----- 2 files changed, 10 insertions(+), 6 deletions(-) (limited to 'client-native-lib') diff --git a/client-native-lib/Cargo.toml b/client-native-lib/Cargo.toml index ea36db9..152ae2a 100644 --- a/client-native-lib/Cargo.toml +++ b/client-native-lib/Cargo.toml @@ -1,6 +1,6 @@ [package] name = "libkeks" -version = "0.2.3" +version = "0.3.0" edition = "2021" [dependencies] 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 } } } -- cgit v1.2.3-70-g09d2