fix: for upstream changes (#2)

* fix: for upstream changes

* fixup! fix: for upstream changes

* fixup! fixup! fix: for upstream changes

* fixup! fixup! fixup! fix: for upstream changes

flow/src/bin/first_ten_distributed.rs

@@ -1,7 +1,7 @@
 #[tokio::main]
 async fn main() {
-    hydroflow_plus::util::cli::launch(|ports| {
-        flow::first_ten_distributed::first_ten_distributed_runtime!(&ports)
+    hydroflow_plus::util::cli::launch!(|ports| {
+        flow::first_ten_distributed::first_ten_distributed_runtime!(ports)
     })
     .await;
 }

flow/src/first_ten.rs

@@ -9,7 +9,7 @@ pub fn first_ten<'a, D: LocalDeploy<'a>>(
 ) {
     let process = flow.process(process_spec);
 
-    let numbers = process.source_iter(q!(0..10));
+    let numbers = flow.source_iter(&process, q!(0..10));
     numbers.for_each(q!(|n| println!("{}", n)));
 }
 

flow/src/first_ten_distributed.rs

@@ -8,7 +8,7 @@ pub fn first_ten_distributed<'a, D: Deploy<'a>>(
     let process = flow.process(process_spec);
     let second_process = flow.process(process_spec);
 
-    let numbers = process.source_iter(q!(0..10));
+    let numbers = flow.source_iter(&process, q!(0..10));
     numbers
         .send_bincode(&second_process)
         .for_each(q!(|n| println!("{}", n)));

flow/src/lib.rs

@@ -1,5 +1,11 @@
 stageleft::stageleft_crate!(flow_macro);
 
+#[cfg(stageleft_macro)]
+pub(crate) mod first_ten;
+#[cfg(not(stageleft_macro))]
 pub mod first_ten;
 
+#[cfg(stageleft_macro)]
+pub(crate) mod first_ten_distributed;
+#[cfg(not(stageleft_macro))]
 pub mod first_ten_distributed;

flow_macro/Cargo.toml

@@ -6,7 +6,7 @@ edition = "2021"
 
 [lib]
 proc-macro = true
-path = "src/lib.rs"
+path = "../flow/src/lib.rs"
 
 [features]
 default = ["macro"]