remove unnecessary clone in BatchLogger

Signed-off-by: Andrea Lattuada <andrea.lattuada@inf.ethz.ch>
TimelyDataflow · Jan 4, 2018 · a79c493 · a79c493
1 parent d3fce80
commit a79c493
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/logging.rs b/src/logging.rs
@@ -90,8 +90,8 @@ impl<S: Clone, E: Clone, P> BatchLogger<S, E, P> where P: EventPusher<Product<Ro
         match logger_batch {
             LoggerBatch::Logs(evs) => {
                 if let Some(frontier) = self.frontier {
-                    self.event_pusher.push(Event::Messages(frontier, evs.clone()));
                     let &(last_ts, _, _) = evs.last().unwrap();
+                    self.event_pusher.push(Event::Messages(frontier, evs));
                     let new_frontier = RootTimestamp::new(last_ts);
                     self.event_pusher.push(Event::Progress(vec![(new_frontier, 1), (frontier, -1)]));
                     self.frontier = Some(new_frontier);