reader.feed_eof()
else:
reader.set_exception(exc)
-
+
if fd in self._pipe_fds:
self._pipe_fds.remove(fd)
self._maybe_close_transport()
def process_exited(self):
self._process_exited = True
self._maybe_close_transport()
-
+
def _maybe_close_transport(self):
if len(self._pipe_fds) == 0 and self._process_exited:
self._transport.close()
'sys.stdout.flush()',
'sys.exit(1)'])
- fut = asyncio.create_subprocess_exec(sys.executable, '-c', code,
- stdout=asyncio.subprocess.PIPE,
- loop=self.loop)
+ fut = asyncio.create_subprocess_exec(
+ sys.executable, '-c', code,
+ stdout=asyncio.subprocess.PIPE,
+ loop=self.loop)
+
process = yield from fut
while True:
data = yield from process.stdout.read(65536)
break
self.loop.run_until_complete(execute())
-
+
if sys.platform != 'win32':
# Unix