Function servers::postgres::handler::recordbatches_to_query_response

source ยท
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,