feedback ds

src/sinks/honeycomb/sink.rs

@@ -34,7 +34,6 @@ where
     }
 
     async fn run_inner(self: Box<Self>, input: BoxStream<'_, Event>) -> Result<(), ()> {
-        let service = ServiceBuilder::new().service(self.service);
         input
             // Batch the input stream with size calculation based on the estimated encoded json size
             .batched(
@@ -55,7 +54,7 @@ where
             })
             // Generate the driver that will send requests and handle retries,
             // event finalization, and logging/internal metric reporting.
-            .into_driver(service)
+            .into_driver(self.service)
             .run()
             .await
     }