fix(mapper): Panic on inter-stage channel error (#70)

txpipe · Jan 16, 2022 · 83896b5 · 83896b5
1 parent acd8441
commit 83896b5
Showing 1 changed file with 4 additions and 10 deletions.
diff --git a/src/mapper/prelude.rs b/src/mapper/prelude.rs
@@ -78,7 +78,9 @@ impl EventWriter {
             fingerprint: None,
         };
 
-        self.output.send(evt)?;
+        self.output
+            .send(evt)
+            .expect("error sending event through output stage, pipeline must have crashed.");
 
         Ok(())
     }
@@ -87,15 +89,7 @@ impl EventWriter {
     where
         T: Into<EventData>,
     {
-        let evt = Event {
-            context: self.context.clone(),
-            data: source.into(),
-            fingerprint: None,
-        };
-
-        self.output.send(evt)?;
-
-        Ok(())
+        self.append(source.into())
     }
 
     pub fn child_writer(&self, mut extra_context: EventContext) -> EventWriter {