diff options
| author | Hrvoje Nikšić <hniksic@gmail.com> | 2019-09-17 07:16:43 (GMT) |
|---|---|---|
| committer | Miss Islington (bot) <31488909+miss-islington@users.noreply.github.com> | 2019-09-17 07:16:43 (GMT) |
| commit | 5d359cc62e0244e1fd8d17146a4135079d6843bf (patch) | |
| tree | 9ec604a23df938bc1f44b56838e4b4435d1add5d | |
| parent | f669581a9527afb0d2325f9845a86715c0ba365d (diff) | |
| download | cpython-5d359cc62e0244e1fd8d17146a4135079d6843bf.zip cpython-5d359cc62e0244e1fd8d17146a4135079d6843bf.tar.gz cpython-5d359cc62e0244e1fd8d17146a4135079d6843bf.tar.bz2 | |
bpo-38192: Fix remaining passing of "loop" in the protocol examples (GH-16202)
See https://bugs.python.org/issue38192 .
https://bugs.python.org/issue38192
| -rw-r--r-- | Doc/library/asyncio-protocol.rst | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/Doc/library/asyncio-protocol.rst b/Doc/library/asyncio-protocol.rst index ca37581..cb0317e 100644 --- a/Doc/library/asyncio-protocol.rst +++ b/Doc/library/asyncio-protocol.rst @@ -792,7 +792,7 @@ data, and waits until the connection is closed:: message = 'Hello World!' transport, protocol = await loop.create_connection( - lambda: EchoClientProtocol(message, on_con_lost, loop), + lambda: EchoClientProtocol(message, on_con_lost), '127.0.0.1', 8888) # Wait until the protocol signals that the connection @@ -870,8 +870,8 @@ method, sends data and closes the transport when it receives the answer:: class EchoClientProtocol: def __init__(self, message, on_con_lost): self.message = message - self.transport = None self.on_con_lost = on_con_lost + self.transport = None def connection_made(self, transport): self.transport = transport @@ -927,9 +927,9 @@ Wait until a socket receives data using the class MyProtocol(asyncio.Protocol): - def __init__(self, loop): + def __init__(self, on_con_lost): 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 @@ -950,13 +950,14 @@ Wait until a socket receives data using the # Get a reference to the event loop as we plan to use # low-level APIs. loop = asyncio.get_running_loop() + on_con_lost = loop.create_future() # Create a pair of connected sockets rsock, wsock = socket.socketpair() # Register the socket to wait for data. transport, protocol = await loop.create_connection( - lambda: MyProtocol(loop), sock=rsock) + lambda: MyProtocol(on_con_lost), sock=rsock) # Simulate the reception of data from the network. loop.call_soon(wsock.send, 'abc'.encode()) |