Module subscribe 

Enums

CreateSubscriptionError

Error type for subscription creation.

Functions

cleanup_subscription

Async cleanup via the compute pool.

cleanup_subscription_sync

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

create_subscription

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