Function process_csv_stream 

pub async fn process_csv_stream<R>(
    reader: R,
    required_headers: &[&str],
) -> CsvResult<CsvIngestSummary>
where
    R: AsyncRead + Unpin + Send + 'static,

Streaming parse with required header validation. This mirrors your existing logic as closely as possible.