[Python-checkins] cpython (3.4): asyncio doc: enhance TCP client example
victor.stinner
python-checkins at python.org
Sun Oct 12 11:35:34 CEST 2014
https://hg.python.org/cpython/rev/64a8f20488c4
changeset: 92987:64a8f20488c4
branch: 3.4
user: Victor Stinner <victor.stinner at gmail.com>
date: Sun Oct 12 11:35:09 2014 +0200
summary:
asyncio doc: enhance TCP client example
files:
Doc/library/asyncio-protocol.rst | 19 ++++++++++++-------
1 files changed, 12 insertions(+), 7 deletions(-)
diff --git a/Doc/library/asyncio-protocol.rst b/Doc/library/asyncio-protocol.rst
--- a/Doc/library/asyncio-protocol.rst
+++ b/Doc/library/asyncio-protocol.rst
@@ -447,21 +447,26 @@
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 @@
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()
--
Repository URL: https://hg.python.org/cpython
More information about the Python-checkins
mailing list