bpo-38192: Fix remaining passing of "loop" in the protocol examples (GH-16202)
See https://bugs.python.org/issue38192 .
https://bugs.python.org/issue38192
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 @@
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 @@
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 @@
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 @@
# 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())