Skip to content

Commit 02d99b5

Browse files
committed
Rename to relax
Signed-off-by: Moritz Hoffmann <[email protected]>
1 parent 67385de commit 02d99b5

File tree

4 files changed

+4
-4
lines changed

4 files changed

+4
-4
lines changed

container/src/lib.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -130,7 +130,7 @@ pub trait ContainerBuilder: Default + 'static {
130130
/// not rely on this method releasing any internal state though, i.e., the caller first
131131
/// needs to drain the contents using [`Self::finish`].
132132
#[inline]
133-
fn flush(&mut self) { }
133+
fn relax(&mut self) { }
134134
}
135135

136136
/// A wrapper trait indicating that the container building will preserve the number of records.

timely/examples/columnar.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -334,7 +334,7 @@ mod builder {
334334
}
335335

336336
#[inline]
337-
fn flush(&mut self) {
337+
fn relax(&mut self) {
338338
*self = Self::default();
339339
}
340340
}

timely/src/dataflow/channels/pushers/buffer.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -81,7 +81,7 @@ impl<T, CB: ContainerBuilder, P: Push<Message<T, CB::Container>>> Buffer<T, CB,
8181
/// Flushes all data and pushes a `None` to `self.pusher`, indicating a flush.
8282
pub fn cease(&mut self) {
8383
self.flush();
84-
self.builder.flush();
84+
self.builder.relax();
8585
self.pusher.push(&mut None);
8686
}
8787

timely/src/dataflow/channels/pushers/exchange.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -96,7 +96,7 @@ where
9696
// flush
9797
for index in 0..self.pushers.len() {
9898
self.flush(index);
99-
self.builders[index].flush();
99+
self.builders[index].relax();
100100
self.pushers[index].push(&mut None);
101101
}
102102
}

0 commit comments

Comments
 (0)