`eventstoredb.subscriptions`#

Module Contents#

Classes#

PersistentSubscription

Attributes#

class eventstoredb.subscriptions.PersistentSubscription(channel, read_request)[source]#

Bases: collections.abc.AsyncIterator[eventstoredb.events.PersistentSubscriptionEvent]

Parameters:

channel (grpclib.client.Channel) –
read_request (eventstoredb.generated.event_store.client.persistent_subscriptions.ReadReq) –

__aiter__()[source]#

Return type:: collections.abc.AsyncIterator[eventstoredb.events.PersistentSubscriptionEvent]

async __anext__()[source]#

Return the next item or raise StopAsyncIteration when exhausted.

Return type:: eventstoredb.events.PersistentSubscriptionEvent

async ack(events)[source]#

Parameters:: events (eventstoredb.events.PersistentSubscriptionEvent | list[eventstoredb.events.PersistentSubscriptionEvent]) –
Return type:: None

async nack(action, reason, events)[source]#

Parameters:

action (eventstoredb.client.subscribe_to_persistent_subscription_to_stream.types.NackAction) –
reason (str) –
events (eventstoredb.events.PersistentSubscriptionEvent | list[eventstoredb.events.PersistentSubscriptionEvent]) –

Return type:

None

eventstoredb.subscriptions.Subscription#