reorder/name to match offline pipeline

stream_pipeline.py

@@ -54,24 +54,24 @@ def shutdown_streamers():
         Streamer_raw = None
 
 
-def set_stt_streamer(model_name: str, fs_hz: int):
+def set_stt_streamer(sample_rate: int, stt_model: str):
     global Streamer_enhanced, Streamer_raw
-    StreamerCls = STREAMER_CLASSES.get(model_name, DeepgramStreamer)
+    StreamerCls = STREAMER_CLASSES.get(stt_model, DeepgramStreamer)
     try:
         Streamer_enhanced = StreamerCls(
-            fs_hz=fs_hz,
-            stream_name="enhanced",
+            fs_hz=sample_rate,
+            stream_name="Enhanced",
             on_update=_set_transcript_enhanced,
         )
         Streamer_raw = StreamerCls(
-            fs_hz=fs_hz,
-            stream_name="raw",
+            fs_hz=sample_rate,
+            stream_name="Raw",
             on_update=_set_transcript_raw,
         )
     except Exception as e:
         Streamer_enhanced = None
         Streamer_raw = None
-        raise RuntimeError(f"Error initializing STT streamer '{model_name}': {e}")
+        raise RuntimeError(f"Error initializing STT streamer '{stt_model}': {e}")
 
 def _to_float32_mono(y: np.ndarray) -> np.ndarray:
     y = np.asarray(y)
@@ -104,7 +104,7 @@ def _ensure_initialized(sr: int, streaming_sr, stt_model: str, enhancement_level
             enhancement_level=enhancement_level
         )
         SDK_STREAMING.init_processor(sdk_params)
-        set_stt_streamer(stt_model, sr)
+        set_stt_streamer(sr, stt_model)
         return sr, *render_system_status("ready")
     except Exception as e:
         gr.Warning(f"Streaming process failed: {e}")