Skip to content

Commit 6bba5fe

Browse files
Make Buffer::push_into private (#649)
1 parent ddfd9b9 commit 6bba5fe

File tree

1 file changed

+5
-11
lines changed
  • timely/src/dataflow/channels/pushers

1 file changed

+5
-11
lines changed

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

+5-11
Original file line numberDiff line numberDiff line change
@@ -114,16 +114,10 @@ impl<T, CB: ContainerBuilder, P: Push<Message<T, CB::Container>>> Buffer<T, CB,
114114
Message::push_at(container, time, &mut self.pusher);
115115
}
116116
}
117-
}
118-
119-
impl<T, CB, P, D> PushInto<D> for Buffer<T, CB, P>
120-
where
121-
T: Eq+Clone,
122-
CB: ContainerBuilder + PushInto<D>,
123-
P: Push<Message<T, CB::Container>>
124-
{
117+
118+
/// An internal implementation of push that should only be called by sessions.
125119
#[inline]
126-
fn push_into(&mut self, item: D) {
120+
fn push_internal<D>(&mut self, item: D) where CB: PushInto<D> {
127121
self.builder.push_into(item);
128122
self.extract_and_send();
129123
}
@@ -189,7 +183,7 @@ where
189183
{
190184
#[inline]
191185
fn push_into(&mut self, item: D) {
192-
self.buffer.push_into(item);
186+
self.buffer.push_internal(item);
193187
}
194188
}
195189

@@ -241,7 +235,7 @@ where
241235
{
242236
#[inline]
243237
fn push_into(&mut self, item: D) {
244-
self.buffer.push_into(item);
238+
self.buffer.push_internal(item);
245239
}
246240
}
247241

0 commit comments

Comments
 (0)