Skip to content

Commit e54fbb1

Browse files
authored
Probe-with does not require mutable reference (#577)
The Timely `probe_with` operator requires a reference to a probe handle, but differential passes a mutable reference. This change adjusts the parameter to be in sync with what Timely requires. Signed-off-by: Moritz Hoffmann <[email protected]>
1 parent 5fb0be6 commit e54fbb1

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/collection.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -165,7 +165,7 @@ impl<G: Scope, D, R, C: Container + Clone + 'static> Collection<G, D, R, C> {
165165
/// In addition, a probe is also often use to limit the number of rounds of input in flight at any moment; a
166166
/// computation can wait until the probe has caught up to the input before introducing more rounds of data, to
167167
/// avoid swamping the system.
168-
pub fn probe_with(&self, handle: &mut probe::Handle<G::Timestamp>) -> Self {
168+
pub fn probe_with(&self, handle: &probe::Handle<G::Timestamp>) -> Self {
169169
Self::new(self.inner.probe_with(handle))
170170
}
171171
/// The scope containing the underlying timely dataflow stream.

0 commit comments

Comments
 (0)