@@ -273,7 +273,6 @@ async fn chat_completions(
273273 . get_chat_completions_engine ( model)
274274 . map_err ( |_| ErrorResponse :: model_not_found ( ) ) ?;
275275
276- // Create separate guards - no Arc/Mutex needed
277276 let mut inflight_guard =
278277 state
279278 . metrics_clone ( )
@@ -429,7 +428,7 @@ async fn monitor_for_disconnects(
429428
430429 // Stream completed successfully - mark as ok
431430 if tx. send ( Ok ( Event :: default ( ) . data ( "[DONE]" ) ) ) . await . is_ok ( ) {
432- inflight_guard. mark_ok ( ) ; // Direct call, no mutex
431+ inflight_guard. mark_ok ( ) ;
433432 }
434433 } ) ;
435434
@@ -446,7 +445,7 @@ impl<T> From<Annotated<T>> for EventConverter<T> {
446445
447446fn process_event_converter < T : Serialize > (
448447 annotated : EventConverter < T > ,
449- response_collector : & mut ResponseMetricCollector , // Direct reference, no Arc/Mutex
448+ response_collector : & mut ResponseMetricCollector ,
450449) -> Result < Event , axum:: Error > {
451450 let annotated = annotated. 0 ;
452451
@@ -466,7 +465,6 @@ fn process_event_converter<T: Serialize>(
466465 event = event. event ( msg) ;
467466 }
468467
469- // Use response_collector directly - no mutex needed
470468 if let Some ( osl) = annotated. output_tokens {
471469 response_collector. observe_current_osl ( osl) ;
472470 }
0 commit comments