from datetime import datetime
import os
import subprocess
+import sys
from typing import Any, Callable
import gi
def stop(self) -> None:
stdin = self.process.stdin
assert stdin is not None
- stdin.write(b'q')
- stdin.flush()
+ try:
+ stdin.write(b'q')
+ stdin.flush()
+ except BrokenPipeError:
+ print("Stream already stopped?", file=sys.stderr)
self.process.wait()