Prepare the structure to implement new multiline logic

Signed-off-by: MOZGIII <mike-n@narod.ru>
vectordotdev · Feb 19, 2020 · 7a685d0 · 7a685d0
1 parent deb5b4c
commit 7a685d0
Show file tree

Hide file tree

Showing 2 changed files with 384 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,