Function recordbatches_to_query_response

fn recordbatches_to_query_response<'a, S>(
    query_ctx: QueryContextRef,
    recordbatches_stream: S,
    schema: SchemaRef,
    field_format: &Format,
) -> PgWireResult<Response<'a>>
where
    S: Stream<Item = Result<RecordBatch>> + Send + Unpin + 'static,