summaryrefslogtreecommitdiff
path: root/Lib/asyncio/subprocess.py
diff options
context:
space:
mode:
authorAndrew Svetlov <andrew.svetlov@gmail.com>2019-09-10 15:56:14 +0300
committerMiss Islington (bot) <31488909+miss-islington@users.noreply.github.com>2019-09-10 05:56:14 -0700
commit12c122ae958a55c9874ed4c7d7805ceb084411d7 (patch)
tree5e5dad44e8cd210e1f8d8348ed5be9695aee4d27 /Lib/asyncio/subprocess.py
parent9a94093189417adddd6b59d6c80cc5544630c8aa (diff)
downloadcpython-git-12c122ae958a55c9874ed4c7d7805ceb084411d7.tar.gz
bpo-38066: Hide internal Stream methods (GH-15762)
feed_eof(), feed_data(), set_exception(), and set_transport() are prefixed with underscore now. https://bugs.python.org/issue38066
Diffstat (limited to 'Lib/asyncio/subprocess.py')
-rw-r--r--Lib/asyncio/subprocess.py10
1 files changed, 5 insertions, 5 deletions
diff --git a/Lib/asyncio/subprocess.py b/Lib/asyncio/subprocess.py
index 2a68c9e4cb..e4f9e5297a 100644
--- a/Lib/asyncio/subprocess.py
+++ b/Lib/asyncio/subprocess.py
@@ -50,7 +50,7 @@ class SubprocessStreamProtocol(streams.FlowControlMixin,
limit=self._limit,
loop=self._loop,
_asyncio_internal=True)
- self.stdout.set_transport(stdout_transport)
+ self.stdout._set_transport(stdout_transport)
self._pipe_fds.append(1)
stderr_transport = transport.get_pipe_transport(2)
@@ -61,7 +61,7 @@ class SubprocessStreamProtocol(streams.FlowControlMixin,
limit=self._limit,
loop=self._loop,
_asyncio_internal=True)
- self.stderr.set_transport(stderr_transport)
+ self.stderr._set_transport(stderr_transport)
self._pipe_fds.append(2)
stdin_transport = transport.get_pipe_transport(0)
@@ -80,7 +80,7 @@ class SubprocessStreamProtocol(streams.FlowControlMixin,
else:
reader = None
if reader is not None:
- reader.feed_data(data)
+ reader._feed_data(data)
def pipe_connection_lost(self, fd, exc):
if fd == 0:
@@ -101,9 +101,9 @@ class SubprocessStreamProtocol(streams.FlowControlMixin,
reader = None
if reader is not None:
if exc is None:
- reader.feed_eof()
+ reader._feed_eof()
else:
- reader.set_exception(exc)
+ reader._set_exception(exc)
if fd in self._pipe_fds:
self._pipe_fds.remove(fd)