chore (#19)

Co-authored-by: Omar Sobh <[email protected]>
Co-committed-by: Omar Sobh <[email protected]>

crates/production/rtx-streaming/src/realtime_pipeline/mod.rs

@@ -222,14 +222,14 @@ mod tests {
     #[tokio::test]
     async fn test_realtime_pipeline_creation() {
         let config = PipelineConfig::default();
-        let pipeline = RealtimePipeline::new(config).await;
+        let pipeline = RealtimePipeline::new(config);
         assert!(pipeline.is_ok());
     }
 
     #[tokio::test]
     async fn test_sub_millisecond_processing() {
         let config = PipelineConfig::default();
-        let pipeline = RealtimePipeline::new(config).await.unwrap();
+        let pipeline = RealtimePipeline::new(config).unwrap();
 
         let event_id = Uuid::new_v4();
         let event_time = SystemTime::now();
@@ -265,7 +265,7 @@ mod tests {
     #[tokio::test]
     async fn test_high_throughput_processing() {
         let config = PipelineConfig::default();
-        let pipeline = Arc::new(RealtimePipeline::new(config).await.unwrap());
+        let pipeline = Arc::new(RealtimePipeline::new(config).unwrap());
 
         let start = Instant::now();
         let mut handles = Vec::new();