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