Skip to content

Nats consumer

NatsConsumer

Bases: Consumer

Implementation of a consumer for NATS

disconnect() async

Closes the connection to the server.

RETURNS DESCRIPTION
None

get_message()

Get the published messages of the subscription.

RETURNS DESCRIPTION
message_iterator

An async iterator for the messages.

TYPE: AsyncIterator