summaryrefslogtreecommitdiffstats
path: root/Lib
diff options
context:
space:
mode:
authorYury Selivanov <yury@magic.io>2017-03-03 04:25:31 (GMT)
committerYury Selivanov <yury@magic.io>2017-03-03 04:25:31 (GMT)
commit2f156457856da360a5549dd72f265c56f1b120f8 (patch)
tree53d567a5123baff970c4ec4d026cabc8338ded89 /Lib
parent481cb70a724687d12553d38a749c16034af68a1e (diff)
downloadcpython-2f156457856da360a5549dd72f265c56f1b120f8.zip
cpython-2f156457856da360a5549dd72f265c56f1b120f8.tar.gz
cpython-2f156457856da360a5549dd72f265c56f1b120f8.tar.bz2
asyncio: Fix trailing whitespace/code style
Diffstat (limited to 'Lib')
-rw-r--r--Lib/asyncio/subprocess.py4
-rw-r--r--Lib/test/test_asyncio/test_subprocess.py10
2 files changed, 8 insertions, 6 deletions
diff --git a/Lib/asyncio/subprocess.py b/Lib/asyncio/subprocess.py
index 06c7d4f..4c85466 100644
--- a/Lib/asyncio/subprocess.py
+++ b/Lib/asyncio/subprocess.py
@@ -89,7 +89,7 @@ class SubprocessStreamProtocol(streams.FlowControlMixin,
reader.feed_eof()
else:
reader.set_exception(exc)
-
+
if fd in self._pipe_fds:
self._pipe_fds.remove(fd)
self._maybe_close_transport()
@@ -97,7 +97,7 @@ class SubprocessStreamProtocol(streams.FlowControlMixin,
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()
diff --git a/Lib/test/test_asyncio/test_subprocess.py b/Lib/test/test_asyncio/test_subprocess.py
index 407e8b6..2e14a8a 100644
--- a/Lib/test/test_asyncio/test_subprocess.py
+++ b/Lib/test/test_asyncio/test_subprocess.py
@@ -468,9 +468,11 @@ class SubprocessMixin:
'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)
@@ -480,7 +482,7 @@ class SubprocessMixin:
break
self.loop.run_until_complete(execute())
-
+
if sys.platform != 'win32':
# Unix