They be Arc'd

Author: bbqsrc

src/ast/mod.rs

@@ -352,11 +352,11 @@ impl Pipe {
         })
     }
 
-    pub fn command<T: CommandRunner>(&self, key: &str) -> Option<&T> {
+    pub fn command<T: CommandRunner>(&self, key: &str) -> Option<&Arc<T>> {
         self.modules
             .get(key)
             .map(|x| x as &dyn Any)
-            .and_then(|x| x.downcast_ref::<T>())
+            .and_then(|x| x.downcast_ref::<Arc<T>>())
     }
 
     pub async fn create_stream(

src/lib.rs

@@ -211,7 +211,7 @@ impl Bundle {
         &self.pipe.defn
     }
 
-    pub fn command<T: modules::CommandRunner>(&self, key: &str) -> Option<&T> {
+    pub fn command<T: modules::CommandRunner>(&self, key: &str) -> Option<&Arc<T>> {
         self.pipe.command(key)
     }
 }