fix(core/supervisor): pre-spawn actors in Multicast to avoid deadlock (…

…#105)
elfo-rs · Aug 11, 2023 · 7e56faf · 7e56faf
1 parent 9c41531
commit 7e56faf
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/elfo-core/src/supervisor.rs b/elfo-core/src/supervisor.rs
@@ -226,7 +226,12 @@ where
                 None => visitor.empty(envelope),
             },
             Outcome::Multicast(list) => {
-                let iter = list.into_iter().filter_map(|key| get_or_spawn!(self, key));
+                for key in list.iter() {
+                    if !self.objects.contains_key(key) {
+                        get_or_spawn!(self, key.clone());
+                    }
+                }
+                let iter = list.into_iter().filter_map(|key| self.objects.get(&key));
                 self.visit_multiple(envelope, visitor, iter);
             }
             Outcome::GentleMulticast(list) => {