Skip to content

Commit 13a2b43

Browse files
committed
Remove unneeded is_empty check
Signed-off-by: Moritz Hoffmann <[email protected]>
1 parent 5095ff4 commit 13a2b43

File tree

1 file changed

+1
-3
lines changed

1 file changed

+1
-3
lines changed

timely/src/dataflow/operators/core/filter.rs

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -30,9 +30,7 @@ where
3030
fn filter<P: FnMut(&C::Item<'_>)->bool+'static>(&self, mut predicate: P) -> StreamCore<G, C> {
3131
self.unary(Pipeline, "Filter", move |_,_| move |input, output| {
3232
input.for_each(|time, data| {
33-
if !data.is_empty() {
34-
output.session(&time).give_iterator(data.drain().filter(&mut predicate));
35-
}
33+
output.session(&time).give_iterator(data.drain().filter(&mut predicate));
3634
});
3735
})
3836
}

0 commit comments

Comments
 (0)