Function capture_stream 

pub async fn capture_stream<S>(
    store: &PgStore,
    stream_name: &str,
    tenant: &str,
    object: &ObjectSync,
    stream: S,
) -> Result<usize, ForceSyncError>
where
    S: Stream<Item = Result<PubSubEvent<Value>, PubSubError>> + Unpin,

Captures a decoded CDC stream into the sync journal and checkpoints replay positions.

Errors

Returns an error if Pub/Sub decoding, journal writes, or checkpoint updates fail.