Function subscribe_stream_with_errors 

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

Creates an async Stream that also yields errors.

Returns a ChangeEventResultStream that yields Result<ChangeEvent, PushSubscriptionError>, allowing explicit handling of lagged events.

Arguments

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