diff options
author | Hrvoje Nikšić <hniksic@gmail.com> | 2019-09-15 17:06:02 (GMT) |
---|---|---|
committer | Miss Islington (bot) <31488909+miss-islington@users.noreply.github.com> | 2019-09-15 17:06:02 (GMT) |
commit | c717c73fa33a2f3591442059eaf6e7a673e2c725 (patch) | |
tree | d747f4eb42d720ff831816845e33a1ab2868817c | |
parent | 6e27a0d77520bf2c4412e367496212510f81b983 (diff) | |
download | cpython-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
-rw-r--r-- | Doc/library/asyncio-protocol.rst | 14 |
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() |