Function create_peek_response_stream 

pub(crate) fn create_peek_response_stream(
    rows_rx: Receiver<PeekResponse>,
    finishing: RowSetFinishing,
    max_result_size: u64,
    max_returned_query_size: Option<u64>,
    duration_histogram: Histogram,
    persist_client: PersistClient,
    peek_stash_read_batch_size_bytes: usize,
    peek_stash_read_memory_budget_bytes: usize,
) -> impl Stream<Item = PeekResponseUnary>

Creates an async stream that processes peek responses and yields rows.