summaryrefslogtreecommitdiff
path: root/docs/using_asyncio.rst
diff options
context:
space:
mode:
authormathieui <mathieui@mathieui.net>2022-02-15 20:58:20 +0100
committermathieui <mathieui@mathieui.net>2022-02-15 20:58:20 +0100
commit22b00c607306c10202c41cdc02ceb633e9f91740 (patch)
tree7304c5dbd015ebfc951b6889c20db04ceb437e45 /docs/using_asyncio.rst
parent92c3f69829fad6e77e25aab64bdbcf988d937994 (diff)
parenta50bffae890f52295e91603178597023140438ca (diff)
downloadslixmpp-22b00c607306c10202c41cdc02ceb633e9f91740.tar.gz
slixmpp-22b00c607306c10202c41cdc02ceb633e9f91740.tar.bz2
slixmpp-22b00c607306c10202c41cdc02ceb633e9f91740.tar.xz
slixmpp-22b00c607306c10202c41cdc02ceb633e9f91740.zip
Merge branch 'update-doc-yieldfrom' into 'master'
docs: remove yield from and fix some old changes See merge request poezio/slixmpp!182
Diffstat (limited to 'docs/using_asyncio.rst')
-rw-r--r--docs/using_asyncio.rst35
1 files changed, 14 insertions, 21 deletions
diff --git a/docs/using_asyncio.rst b/docs/using_asyncio.rst
index 55ed7679..ca85b7c6 100644
--- a/docs/using_asyncio.rst
+++ b/docs/using_asyncio.rst
@@ -11,7 +11,7 @@ Block on IQ sending
.. code-block:: python
- result = yield from iq.send()
+ result = await iq.send()
.. warning::
@@ -28,13 +28,7 @@ The same changes from the SleekXMPP API apply, so you can do:
.. code-block:: python
- iq_info = yield from self.xmpp['xep_0030'].get_info(jid)
-
-But the following will only return a Future:
-
-.. code-block:: python
-
- iq_info = self.xmpp['xep_0030'].get_info(jid)
+ iq_info = await self.xmpp['xep_0030'].get_info(jid)
Callbacks, Event Handlers, and Stream Handlers
@@ -42,7 +36,7 @@ Callbacks, Event Handlers, and Stream Handlers
IQ callbacks and :term:`Event Handlers <event handler>` can be coroutine
functions; in this case, they will be scheduled in the event loop using
-:meth:`.asyncio.async` and not ran immediately.
+:meth:`.asyncio.ensure_future` and not ran immediately.
A :class:`.CoroutineCallback` class has been added as well for
:term:`Stream Handlers <stream handler>`, which will use
@@ -94,18 +88,18 @@ a simple <message>.
.. code-block:: python
- import asyncio, aiohttp, slixmpp
+ import aiohttp, slixmpp
- @asyncio.coroutine
- def get_pythonorg(event):
- req = yield from aiohttp.request('get', 'http://www.python.org')
- text = yield from req.text
+ async def get_pythonorg(event):
+ async with aiohttp.ClientSession() as session:
+ async with session.get('http://www.python.org') as resp:
+ text = await req.text()
client.send_message(mto='jid2@example', mbody=text)
- @asyncio.coroutine
- def get_asyncioorg(event):
- req = yield from aiohttp.request('get', 'http://www.asyncio.org')
- text = yield from req.text
+ async def get_asyncioorg(event):
+ async with aiohttp.ClientSession() as session:
+ async with session.get('http://www.asyncio.org') as resp:
+ text = await req.text()
client.send_message(mto='jid3@example', mbody=text)
client = slixmpp.ClientXMPP('jid@example', 'password')
@@ -132,11 +126,10 @@ JID indicating its findings.
self.register_plugin('xep_0092')
self.add_event_handler('message', self.on_message)
- @asyncio.coroutine
- def on_message(self, event):
+ async def on_message(self, event):
# You should probably handle IqError and IqTimeout exceptions here
# but this is an example.
- version = yield from self['xep_0092'].get_version(message['from'])
+ version = await self['xep_0092'].get_version(message['from'])
text = "%s sent me a message, he runs %s" % (message['from'],
version['software_version']['name'])
self.send_message(mto='master@example.tld', mbody=text)