1 files changed, 6 insertions, 1 deletions
diff --git a/src/output/pipeline.rs b/src/output/pipeline.rs
index 9664928..9b7f461 100644
--- a/src/output/pipeline.rs
+++ b/src/output/pipeline.rs
@@ -22,8 +22,13 @@ impl Pipeline {
         }
     }
 
-    pub fn push_item(&self, item: &LogResult) {
+    pub fn push_item(&self, item: LogResult) {
         let mut writer = self.writer.lock().unwrap();
         self.aggregator.push_item(item, &*self.format, &mut *writer);
     }
+
+    pub fn finish(self) {
+        let mut writer = self.writer.lock().unwrap();
+        self.aggregator.finish(&*self.format, &mut *writer);
+    }
 }