summaryrefslogtreecommitdiffstats
path: root/Doc/library/asyncio-protocol.rst
diff options
context:
space:
mode:
authorHrvoje Nikšić <hniksic@gmail.com>2019-09-15 17:06:02 (GMT)
committerMiss Islington (bot) <31488909+miss-islington@users.noreply.github.com>2019-09-15 17:06:02 (GMT)
commitc717c73fa33a2f3591442059eaf6e7a673e2c725 (patch)
treed747f4eb42d720ff831816845e33a1ab2868817c /Doc/library/asyncio-protocol.rst
parent6e27a0d77520bf2c4412e367496212510f81b983 (diff)
downloadcpython-c717c73fa33a2f3591442059eaf6e7a673e2c725.zip
cpython-c717c73fa33a2f3591442059eaf6e7a673e2c725.tar.gz
cpython-c717c73fa33a2f3591442059eaf6e7a673e2c725.tar.bz2
bpo-38178: Don't explicitly pass "loop" to EchoClientProtocol. (GH-16159)
https://bugs.python.org/issue38178
Diffstat (limited to 'Doc/library/asyncio-protocol.rst')
-rw-r--r--Doc/library/asyncio-protocol.rst14
1 files changed, 7 insertions, 7 deletions
diff --git a/Doc/library/asyncio-protocol.rst b/Doc/library/asyncio-protocol.rst
index 3e5a4dd..ca37581 100644
--- a/Doc/library/asyncio-protocol.rst
+++ b/Doc/library/asyncio-protocol.rst
@@ -767,9 +767,8 @@ data, and waits until the connection is closed::
class EchoClientProtocol(asyncio.Protocol):
- def __init__(self, message, on_con_lost, loop):
+ def __init__(self, message, on_con_lost):
self.message = message
- self.loop = loop
self.on_con_lost = on_con_lost
def connection_made(self, transport):
@@ -869,11 +868,10 @@ method, sends data and closes the transport when it receives the answer::
class EchoClientProtocol:
- def __init__(self, message, loop):
+ def __init__(self, message, on_con_lost):
self.message = message
- self.loop = loop
self.transport = None
- self.on_con_lost = loop.create_future()
+ self.on_con_lost = on_con_lost
def connection_made(self, transport):
self.transport = transport
@@ -899,13 +897,15 @@ method, sends data and closes the transport when it receives the answer::
# low-level APIs.
loop = asyncio.get_running_loop()
+ on_con_lost = loop.create_future()
message = "Hello World!"
+
transport, protocol = await loop.create_datagram_endpoint(
- lambda: EchoClientProtocol(message, loop),
+ lambda: EchoClientProtocol(message, on_con_lost),
remote_addr=('127.0.0.1', 9999))
try:
- await protocol.on_con_lost
+ await on_con_lost
finally:
transport.close()