|
|
@ -151,7 +151,7 @@ class FFmpegAudio(AudioSource): |
|
|
|
|
|
|
|
self._process: subprocess.Popen = self._spawn_process(args, **kwargs) |
|
|
|
self._stdout: IO[bytes] = self._process.stdout # type: ignore |
|
|
|
self._stdin: Optional[IO[Bytes]] = None |
|
|
|
self._stdin: Optional[IO[bytes]] = None |
|
|
|
self._pipe_thread: Optional[threading.Thread] = None |
|
|
|
|
|
|
|
if piping: |
|
|
@ -200,7 +200,7 @@ class FFmpegAudio(AudioSource): |
|
|
|
self._process.terminate() |
|
|
|
return |
|
|
|
try: |
|
|
|
self._stdin.write(data) |
|
|
|
self._stdin.write(data) # type: ignore |
|
|
|
except Exception: |
|
|
|
_log.debug('Write error for %s, this is probably not a problem', self, exc_info=True) |
|
|
|
# at this point the source data is either exhausted or the process is fubar |
|
|
|