summaryrefslogtreecommitdiffstats
path: root/Lib/asyncio/unix_events.py
diff options
context:
space:
mode:
authorYury Selivanov <yury@magic.io>2016-09-12 01:11:02 (GMT)
committerYury Selivanov <yury@magic.io>2016-09-12 01:11:02 (GMT)
commita05a6ef1ca781e2f98fb4332284aca649f24f75d (patch)
treed67a01ecdd45ef3301d88afcb63e80450a30b6da /Lib/asyncio/unix_events.py
parent06e18a7c2473e6d1e8be3dee5c9232ab934e1ef2 (diff)
downloadcpython-a05a6ef1ca781e2f98fb4332284aca649f24f75d.zip
cpython-a05a6ef1ca781e2f98fb4332284aca649f24f75d.tar.gz
cpython-a05a6ef1ca781e2f98fb4332284aca649f24f75d.tar.bz2
asyncio: Add set_protocol / get_protocol methods to Transports
Diffstat (limited to 'Lib/asyncio/unix_events.py')
-rw-r--r--Lib/asyncio/unix_events.py12
1 files changed, 12 insertions, 0 deletions
diff --git a/Lib/asyncio/unix_events.py b/Lib/asyncio/unix_events.py
index 18519fc..f7f9eb2 100644
--- a/Lib/asyncio/unix_events.py
+++ b/Lib/asyncio/unix_events.py
@@ -374,6 +374,12 @@ class _UnixReadPipeTransport(transports.ReadTransport):
def resume_reading(self):
self._loop.add_reader(self._fileno, self._read_ready)
+ def set_protocol(self, protocol):
+ self._protocol = protocol
+
+ def get_protocol(self):
+ return self._protocol
+
def is_closing(self):
return self._closing
@@ -570,6 +576,12 @@ class _UnixWritePipeTransport(transports._FlowControlMixin,
self._loop.remove_reader(self._fileno)
self._loop.call_soon(self._call_connection_lost, None)
+ def set_protocol(self, protocol):
+ self._protocol = protocol
+
+ def get_protocol(self):
+ return self._protocol
+
def is_closing(self):
return self._closing