From c748642f3b801aa5ff4044ab60b0d0c29037a802 Mon Sep 17 00:00:00 2001
From: Daniel <kingdread@gmx.de>
Date: Sat, 4 Apr 2020 14:13:59 +0200
Subject: make pipeline working

---
 src/output/pipeline.rs | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

(limited to 'src/output/pipeline.rs')

diff --git a/src/output/pipeline.rs b/src/output/pipeline.rs
index 9b3c7e5..fb23a6f 100644
--- a/src/output/pipeline.rs
+++ b/src/output/pipeline.rs
@@ -7,12 +7,12 @@ use std::{io::Write, sync::Mutex};
 pub struct Pipeline {
     format: Box<dyn Format>,
     aggregator: Box<dyn Aggregator>,
-    writer: Mutex<Box<dyn Write>>,
+    writer: Mutex<Box<dyn Write + Send>>,
 }
 
 
 impl Pipeline {
-    pub fn new<W: Write + 'static, F: Format + 'static, A: Aggregator + 'static>(writer: W, format: F, aggregator: A) -> Pipeline {
+    pub fn new<W: Write + 'static + Send, F: Format + 'static, A: Aggregator + 'static>(writer: W, format: F, aggregator: A) -> Pipeline {
         Pipeline {
             format: Box::new(format),
             aggregator: Box::new(aggregator),
@@ -22,6 +22,6 @@ impl Pipeline {
 
     pub fn push_item(&self, item: &LogResult) {
         let mut writer = self.writer.lock().unwrap();
-        self.aggregator.push_item(item, &self.format, &mut *writer);
+        self.aggregator.push_item(item, &*self.format, &mut *writer);
     }
 }
-- 
cgit v1.2.3