Terminate Process

CHANGELOG.md

@@ -7,9 +7,11 @@ and this project adheres to [Semantic Versioning](http://semver.org/spec/v2.0.0.
 ## [Unreleased]
 ### Added
 - CLI tests
+- `NavaThread._terminate_process` method
 ### Changed
 - Python typing features added to all modules
 - CLI functions moved to `cli.py`
+- `NavaThread.stop` method updated
 - Dependencies structure modified
 - Test system modified
 ## [0.8] - 2025-12-17

nava/thread.py

@@ -26,6 +26,27 @@ def __init__(self, loop: bool, engine: Engine, *args: List[Any], **kwargs: Dict[
         self._engine = engine
         self._nava_exception = None
 
+    def _terminate_process(self) -> None:
+        """Terminate play process and clean up its standard streams."""
+        try:
+            self._play_process.stdout.close()
+            self._play_process.stdin.close()
+            self._play_process.stderr.close()
+        except Exception:  # nosec B110 - Best effort cleanup
+            pass
+
+        try:
+            self._play_process.terminate()
+            self._play_process.wait(timeout=1)
+        except Exception:
+            try:
+                self._play_process.kill()
+                self._play_process.wait()
+            except Exception:  # nosec B110 - Best effort cleanup
+                pass
+        finally:
+            self._play_process = None
+
     def run(self) -> None:
         """Run target function."""
         try:
@@ -54,26 +75,4 @@ def stop(self) -> None:
             # So the main thread can't "see" the alias created in the worker thread.
         else:
             if self._play_process:
-                # Best-effort: close all standard streams
-                try:
-                    self._play_process.stdout.close()
-                    self._play_process.stdin.close()
-                    self._play_process.stderr.close()
-                except Exception:  # nosec B110 - Best effort cleanup, ignore all errors
-                    # Streams may be None, already closed, or OS-specific issues
-                    pass
-
-                # Try graceful termination
-                try:
-                    self._play_process.terminate()
-                    self._play_process.wait(timeout=1)
-                except Exception:
-                    # Fallback to force kill - catch any process-related errors
-                    try:
-                        self._play_process.kill()
-                        self._play_process.wait()
-                    except Exception:  # nosec B110 - Best effort cleanup, ignore all errors
-                        # Process already terminated or any other issues
-                        pass
-                finally:
-                    self._play_process = None
+                self._terminate_process()

setup.py

@@ -2,6 +2,7 @@
 """Setup module."""
 from setuptools import setup
 
+
 def read_description() -> str:
     """Read README.md and CHANGELOG.md."""
     try: