Prepare the structure to implement new multiline logic

Signed-off-by: MOZGIII <[email protected]>
vectordotdev · Feb 19, 2020 · b179c3d · b179c3d
1 parent deb5b4c
commit b179c3d
Show file tree

Hide file tree

Showing 2 changed files with 378 additions and 39 deletions.
diff --git a/src/sources/file.rs b/src/sources/file.rs
@@ -197,7 +197,7 @@ pub fn file_source(
 
         let messages: Box<dyn Stream<Item = (Bytes, String), Error = ()> + Send> =
             if let Some(msi) = message_start_indicator {
-                Box::new(LineAgg::new(
+                Box::new(LineAgg::new_legacy(
                     rx,
                     Regex::new(&msi).unwrap(), // validated in build
                     multi_line_timeout,