From 2d7625f4b3418c4347e3ce759b35df4e4a93e126 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Botond=20D=C3=A9nes?= <bdenes@scylladb.com>
Date: Thu, 6 Jan 2022 11:01:17 +0200
Subject: [PATCH] flat_mutation_reader_v2: add reader_consumer_v2 typedef

v2 version of the reader_consumer typedef.
---
 flat_mutation_reader_v2.hh | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/flat_mutation_reader_v2.hh b/flat_mutation_reader_v2.hh
index ba751d099b..efed254b5a 100644
--- a/flat_mutation_reader_v2.hh
+++ b/flat_mutation_reader_v2.hh
@@ -827,3 +827,8 @@ make_flat_mutation_reader_from_fragments(schema_ptr, reader_permit, std::deque<m
 
 flat_mutation_reader_v2
 make_flat_mutation_reader_from_fragments(schema_ptr, reader_permit, std::deque<mutation_fragment_v2>, const dht::partition_range& pr, const query::partition_slice& slice);
+
+/// A cosumer function that is passed a flat_mutation_reader to be consumed from
+/// and returns a future<> resolved when the reader is fully consumed, and closed.
+/// Note: the function assumes ownership of the reader and must close it in all cases.
+using reader_consumer_v2 = noncopyable_function<future<> (flat_mutation_reader_v2)>;