fix(transport): use `Process.communicate` instead of `Process.wait` (#2634)
This commit is contained in:
Родитель
67a30645c0
Коммит
8d8d8ab7c7
|
@ -167,7 +167,7 @@ class PipeTransport(Transport):
|
|||
break
|
||||
await asyncio.sleep(0)
|
||||
|
||||
await self._proc.wait()
|
||||
await self._proc.communicate()
|
||||
self._stopped_future.set_result(None)
|
||||
|
||||
def send(self, message: Dict) -> None:
|
||||
|
|
Загрузка…
Ссылка в новой задаче