fixup! fix: for upstream changes

hydro-project · Jun 19, 2024 · 1efca9b · 1efca9b
1 parent 24a1958
commit 1efca9b
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/flow/src/first_ten.rs b/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)));
 }
 

diff --git a/flow/src/first_ten_distributed.rs b/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)));