summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorVictor Stinner <victor.stinner@gmail.com>2014-10-12 09:35:09 (GMT)
committerVictor Stinner <victor.stinner@gmail.com>2014-10-12 09:35:09 (GMT)
commit53664343368a61a2986d3bee3b9b0888376f51c6 (patch)
tree74f94738f81392fa95f8bfd5a7f792a2c7232b66
parentcfbea3a02ebecf59a30b3878f6846ba21f96431c (diff)
downloadcpython-53664343368a61a2986d3bee3b9b0888376f51c6.zip
cpython-53664343368a61a2986d3bee3b9b0888376f51c6.tar.gz
cpython-53664343368a61a2986d3bee3b9b0888376f51c6.tar.bz2
asyncio doc: enhance TCP client example
-rw-r--r--Doc/library/asyncio-protocol.rst19
1 files changed, 12 insertions, 7 deletions
diff --git a/Doc/library/asyncio-protocol.rst b/Doc/library/asyncio-protocol.rst
index 66524c1..487b5ad 100644
--- a/Doc/library/asyncio-protocol.rst
+++ b/Doc/library/asyncio-protocol.rst
@@ -447,21 +447,26 @@ TCP echo client example, send data and wait until the connection is closed::
import asyncio
class EchoClientProtocol(asyncio.Protocol):
- message = 'This is the message. It will be echoed.'
+ def __init__(self, message, loop):
+ self.message = message
+ self.loop = loop
def connection_made(self, transport):
transport.write(self.message.encode())
- print('data sent: {}'.format(self.message))
+ print('Data sent: {!r}'.format(self.message))
def data_received(self, data):
- print('data received: {}'.format(data.decode()))
+ print('Data received: {!r}'.format(data.decode()))
def connection_lost(self, exc):
- print('server closed the connection')
- asyncio.get_event_loop().stop()
+ print('The server closed the connection')
+ print('Stop the event lop')
+ self.loop.stop()
loop = asyncio.get_event_loop()
- coro = loop.create_connection(EchoClientProtocol, '127.0.0.1', 8888)
+ message = 'Hello World!'
+ coro = loop.create_connection(lambda: EchoClientProtocol(message, loop),
+ '127.0.0.1', 8888)
loop.run_until_complete(coro)
loop.run_forever()
loop.close()
@@ -494,7 +499,7 @@ TCP echo server example, send back received data and close the connection::
print('Send: {!r}'.format(message))
self.transport.write(data)
- print('Close the socket')
+ print('Close the client socket')
self.transport.close()
loop = asyncio.get_event_loop()