Function subscribe_stream 

pub fn subscribe_stream(
    registry: Arc<SubscriptionRegistry>,
    source_name: String,
    source_id: u32,
    config: SubscriptionConfig,
) -> ChangeEventStream

Creates an async Stream subscription.

Returns a ChangeEventStream that yields ChangeEvents. Lagged events are silently skipped; the stream terminates when the source is closed or the subscription is cancelled.

Arguments

• registry — Subscription registry.
• source_name — Name of the source MV or query.
• source_id — Ring 0 source identifier.
• config — Subscription configuration.