Struct Subscription 

pub struct Subscription {
    pub id: Ulid,
    /* private fields */
}

Handle to a running event subscription.

Returned by SubscriptionBuilder::start, this handle provides the subscription ID and a method for graceful shutdown.

Example

let subscription = projection
    .subscription()
    .start(&executor)
    .await?;

println!("Started subscription: {}", subscription.id);

// On application shutdown
subscription.shutdown().await?;

Fields

id: Ulid

Unique ID for this subscription instance

Implementations

impl Subscription

pub async fn shutdown(self) -> Result<(), JoinError>

Gracefully shuts down the subscription.

Signals the subscription to stop and waits for it to finish processing the current event before returning.

Trait Implementations

impl Debug for Subscription

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.