Module subscribe 

Enums

CreateSubscriptionError

Error type for subscription creation.

CreateSubscriptionResult

Result of creating a subscription: either local or remote.

Functions

cleanup_subscription

Async cleanup via the compute pool.

cleanup_subscription_sync

Synchronous cleanup: begin subscription txn, drop flow, drop subscription, commit.

create_subscription

Execute CREATE SUBSCRIPTION AS { query } and extract the subscription ID from the result.