pulsar.asyncio

module documentation
(source)

The Pulsar Python client APIs that work with the asyncio module.

Class Client The asynchronous version of pulsar.Client.
Class Consumer The Pulsar message consumer, used to subscribe to messages from a topic.
Class Producer The Pulsar message producer, used to publish messages on a topic.
Class Reader The Pulsar topic reader, used to read messages from a topic.
Exception PulsarException The exception that wraps the Pulsar error code
Function _set_future Undocumented
Function _set_future_v2 Undocumented
def _set_future(future: asyncio.Future, result: _pulsar.Result, value: Any): (source)

Undocumented

def _set_future_v2(future: asyncio.Future, value: Any): (source)

Undocumented