rti.asyncio

Note

This module requires Python 3.7 or newer

This module must be imported in order to use the methods rti.connextdds.DataReader.take_async() and rti.connextdds.DataReader.take_data_async().

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

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.

See Subscriptions.

rti.asyncio.run(coroutine)

Uses the current event loop to run the given coroutine and waits until it finishes. If there is no current running event loop, a new one is created