refactor: update disconnect logic in VoiceAgentClient

sdk/voice/speechmatics/voice/_client.py

@@ -574,33 +574,31 @@ async def disconnect(self) -> None:
         """
 
         # Check if we are already connected
-        if not self._is_connected:
-            return
-
-        # Update the closing session flag
-        self._closing_session = True
-
-        # Emit final segments
-        await self._emit_segments(finalize=True, is_eou=True)
+        if self._is_connected:
+            # Update the closing session flag
+            self._closing_session = True
 
-        # Emit final metrics
-        self._emit_speaker_metrics()
-        self._emit_metrics()
+            # Emit final segments
+            await self._emit_segments(finalize=True, is_eou=True)
 
-        # Stop audio and metrics tasks
-        self._is_ready_for_audio = False
-        self._stop_metrics_task()
+            # Emit final metrics
+            self._emit_speaker_metrics()
+            self._emit_metrics()
 
-        # end session
-        try:
-            await asyncio.wait_for(self.stop_session(), timeout=5.0)
-        except Exception as e:
-            self._logger.error(f"Error closing session: {e}")
-        finally:
-            self._is_connected = False
+            # Stop audio and metrics tasks
+            self._is_ready_for_audio = False
+            self._stop_metrics_task()
 
-        # Stop end of turn-related tasks
-        self._turn_handler.cancel_tasks()
+            # end session
+            try:
+                await asyncio.wait_for(self.stop_session(), timeout=5.0)
+            except Exception as e:
+                self._logger.error(f"Error closing session: {e}")
+            finally:
+                self._is_connected = False
+
+            # Stop end of turn-related tasks
+            self._turn_handler.cancel_tasks()
 
         # Stop the STT queue task
         if self._stt_queue_task: