Compatibility with latest timely

Signed-off-by: Moritz Hoffmann <antiguru@gmail.com>
TimelyDataflow · Mar 19, 2024 · a6a0396 · a6a0396
1 parent 250e9c2
commit a6a0396
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/collection.rs b/src/collection.rs
@@ -416,10 +416,10 @@ impl<G: Scope, D: Data, R: Semigroup> Collection<G, D, R> where G::Timestamp: Da
     ///          .inspect_batch(|t,xs| println!("errors @ {:?}: {:?}", t, xs));
     /// });
     /// ```
-    pub fn inspect_batch<F>(&self, func: F) -> Collection<G, D, R>
+    pub fn inspect_batch<F>(&self, mut func: F) -> Collection<G, D, R>
     where F: FnMut(&G::Timestamp, &[(D, G::Timestamp, R)])+'static {
         self.inner
-            .inspect_batch(func)
+            .inspect_batch(move |time, data| func(time, data))
             .as_collection()
     }
     /// Attaches a timely dataflow probe to the output of a Collection.