separate streams by new line

nikhilsinhaparseable · nikhilsinhaparseable · commit 6dacb946b63b · 2025-05-16T06:31:06.000-04:00
diff --git a/src/handlers/http/query.rs b/src/handlers/http/query.rs
@@ -151,7 +151,7 @@ pub async fn query(req: HttpRequest, query_request: Query) -> Result<HttpRespons
                     error!("Failed to parse record batch into JSON: {}", e);
                     json!({})
                 });
-                Ok(Bytes::from(response.to_string()))
+                Ok(Bytes::from(format!("{}\n", response.to_string())))
             }
             Err(e) => Err(actix_web::error::ErrorInternalServerError(e)),
         }

Original file line number	Diff line number	Diff line change
`@@ -151,7 +151,7 @@ pub async fn query(req: HttpRequest, query_request: Query) -> Result<HttpRespons`
`151`	`151`	`error!("Failed to parse record batch into JSON: {}", e);`
`152`	`152`	`json!({})`
`153`	`153`	`});`
`154`		`- Ok(Bytes::from(response.to_string()))`
	`154`	`+ Ok(Bytes::from(format!("{}\n", response.to_string())))`
`155`	`155`	`}`
`156`	`156`	`Err(e) => Err(actix_web::error::ErrorInternalServerError(e)),`
`157`	`157`	`}`