From 82140c09fa6cf9d8d9f9631ec5512f32a3121c04 Mon Sep 17 00:00:00 2001 From: Nova Date: Sun, 19 Jun 2022 23:19:54 -0400 Subject: [PATCH] fix(registry): make add always succeed --- src/core/registry.rs | 4 ++-- src/nodes/data.rs | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/src/core/registry.rs b/src/core/registry.rs index ec35e64..7b835fe 100644 --- a/src/core/registry.rs +++ b/src/core/registry.rs @@ -6,10 +6,10 @@ use std::sync::{Arc, Weak}; pub struct Registry(RwLock>>); impl Registry { - pub fn add(&self, t: T) -> Result> { + pub fn add(&self, t: T) -> Arc { let t_arc = Arc::new(t); self.0.write().insert(Arc::downgrade(&t_arc)); - Ok(t_arc) + t_arc } pub fn get_valid_contents(&self) -> Vec> { self.0 diff --git a/src/nodes/data.rs b/src/nodes/data.rs index d89fc95..1d31a0b 100644 --- a/src/nodes/data.rs +++ b/src/nodes/data.rs @@ -76,7 +76,7 @@ impl PulseSender { ); let sender = Default::default(); - let sender = PULSE_SENDER_REGISTRY.add(sender)?; + let sender = PULSE_SENDER_REGISTRY.add(sender); let _ = node.pulse_sender.set(sender); node.add_local_signal("setMask", PulseSender::set_mask_flex); node.add_local_method("getReceivers", PulseSender::get_receivers_flex); @@ -167,7 +167,7 @@ impl<'a> PulseReceiver { field: Arc::downgrade(&field), mask: Default::default(), }; - let receiver = PULSE_RECEIVER_REGISTRY.add(receiver)?; + let receiver = PULSE_RECEIVER_REGISTRY.add(receiver); let _ = node.pulse_receiver.set(receiver); node.add_local_signal("setMask", PulseReceiver::set_mask_flex); node.add_local_signal("sendData", PulseReceiver::send_data_flex);