Update stt/stt_google.py

stt/stt_google.py

@@ -105,83 +105,44 @@ class GoogleCloudSTT(STTInterface):
             raise
 
     async def stop_streaming(self) -> Optional[TranscriptionResult]:
-        """Stop streaming and clean up all resources"""
-        if not self.is_streaming and not self.stream_thread:
-            log_debug("Already stopped, nothing to do")
+        """Stop streaming and get final result"""
+        if not self.is_streaming:
             return None
-
+            
         try:
-            log_info(f"🛑 Stopping Google STT streaming session #{self.session_id}")
-
-            # Flag'i hemen kapat
+            log_info("🛑 Stopping Google STT streaming...")
+            
             self.is_streaming = False
             self.stop_event.set()
-
-            # Send poison pill to stop request generator
-            if self.audio_queue:
-                try:
-                    self.audio_queue.put(None)
-                except:
-                    pass
-
-            # Thread'i durdur
-            if self.stream_thread and self.stream_thread.is_alive():
-                log_info("⏳ Waiting for stream thread to finish...")
+            
+            # Send poison pill to queue
+            self.audio_queue.put(None)
+            
+            # Wait for thread to finish
+            if self.stream_thread:
                 self.stream_thread.join(timeout=5.0)
-
-                if self.stream_thread.is_alive():
-                    log_warning("⚠️ STT thread did not stop gracefully after 5s")
-                else:
-                    log_info("✅ Stream thread finished")
-
-            # Final result'ı al
+            
+            # Clear queues
+            while not self.audio_queue.empty():
+                try:
+                    self.audio_queue.get_nowait()
+                except queue.Empty:
+                    break
+                    
             final_result = None
-            if self.responses_queue:
-                while not self.responses_queue.empty():
-                    try:
-                        result = self.responses_queue.get_nowait()
-                        if result.is_final:
-                            final_result = result
-                    except:
-                        pass
-
-            # Client'ı kapat
-            if self.client:
+            while not self.responses_queue.empty():
                 try:
-                    if hasattr(self.client, 'transport') and hasattr(self.client.transport, 'close'):
-                        self.client.transport.close()
-                        log_debug("✅ Client transport closed")
-
-                    if hasattr(self.client, '_transport') and hasattr(self.client._transport, '_grpc_channel'):
-                        self.client._transport._grpc_channel.close()
-                        log_debug("✅ gRPC channel closed")
-                except Exception as e:
-                    log_warning(f"⚠️ Error closing Google client: {e}")
-                finally:
-                    self.client = None
-
-            # Queue'ları None yap
-            self.audio_queue = None
-            self.responses_queue = None
-
-            # Diğer değişkenleri resetle
-            self.stream_thread = None
-            self.streaming_config = None
-            self.stop_event.clear()
-
-            log_info(f"✅ Google STT streaming session #{self.session_id} stopped and cleaned")
+                    result = self.responses_queue.get_nowait()  # ✅ get_nowait() kullan, await değil
+                    if result.is_final:
+                        final_result = result
+                except queue.Empty:
+                    break
+            
+            log_info("✅ Google STT streaming stopped")
             return final_result
-
+            
         except Exception as e:
-            log_error(f"❌ Error during stop_streaming", error=str(e))
-            # Force cleanup on error
-            self.is_streaming = False
-            self.stream_thread = None
-            self.client = None
-            self.streaming_config = None
-            self.stop_event.clear()
-            self.audio_queue = None
-            self.responses_queue = None
+            log_error(f"❌ Failed to stop Google STT streaming", error=str(e))
             return None
     
     def supports_realtime(self) -> bool: