split

OxfordAbstracts · Oct 22, 2024 · 527532d · 527532d
1 parent c15cd9f
commit 527532d
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/metrics/src/logreceiver.rs b/metrics/src/logreceiver.rs
@@ -18,7 +18,9 @@ async fn receive_log(
         while let Some(msg) = stream.next().await {
             match msg {
                 Ok(Message::Text(text)) => {
-                    let _ = logprocessor::log_processor(&text.trim().to_string(), &metric_obj, &tracer).await;
+                    for line in text.split("\n") {
+                        let _ = logprocessor::log_processor(&line.trim().to_string(), &metric_obj, &tracer).await;
+                    }
                     session.text("{\"success\": true}").await.unwrap();
                 }