Function run_stream_loop 

pub async fn run_stream_loop(
    source_id: String,
    config: RisLiveSourceConfig,
    dispatchers: Arc<RwLock<Vec<Box<dyn ChangeDispatcher<SourceEventWrapper> + Send + Sync>>>>,
    state_store: Option<Arc<dyn StateStoreProvider>>,
    shutdown_rx: Receiver<bool>,
) -> Result<()>

Runs the resilient streaming loop with reconnect behavior.