We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent c9d373a commit 577d76fCopy full SHA for 577d76f
src/dataflow/operators/inspect.rs
@@ -30,7 +30,7 @@ pub trait Inspect<G: Scope, D: Data> {
30
/// .inspect_batch(|t,xs| println!("seen at: {:?}\t{:?} records", t, xs.len()));
31
/// });
32
/// ```
33
- fn inspect_batch<F: FnMut(&G::Timestamp, &[D])+'static>(&self, mut func: F) -> Self;
+ fn inspect_batch<F: FnMut(&G::Timestamp, &[D])+'static>(&self, func: F) -> Self;
34
}
35
36
impl<G: Scope, D: Data> Inspect<G, D> for Stream<G, D> {
0 commit comments