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 a blocking task.

cleanup_subscription_sync

Synchronous cleanup: drop subscription via DDL.

create_subscription

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

extract_subscription_id

Extract the subscription ID from frames returned by engine.subscribe_as.