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)>;