rti.asyncio
~~~~~~~~~~~

This module must be imported in order to use the methods
:meth:`rti.connextdds.DataReader.take_async`
and :meth:`rti.connextdds.DataReader.take_data_async`.

These two methods are added to the DataReader class when this module is
imported.

The module also defines ``rti.asyncio.Application``, an easy way to
subscribe to topics by decorating functions that receive each topic update.

The module also defines a convenience function ``rti.asyncio.run``, which
is similar to ``asyncio.run``, and can synchronously run the main async function
in an application, as well as perform certain cleanup tasks at the end.

See :ref:`reader:Subscriptions`.

.. automodule:: rti.asyncio
   :members: