bahman/scylla
1
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

introduce the MutationConsumer concept

Browse Source 
Signed-off-by: Michael Livshin <michael.livshin@scylladb.com>
This commit is contained in:
Michael Livshin
2022-02-27 22:31:43 +02:00
parent 68cfb6261f
commit ce8f34f5a0
1 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
mutation_consumer_concepts.hh
View File

@@ -41,6 +41,14 @@ concept FlatMutationReaderConsumerV2 =
{ c(std::move(mf)) } -> std::same_as<future<stop_iteration>>;
};
template<typename Consumer>
concept MutationConsumer =
requires(Consumer c, mutation m) {
{ c(std::move(m)) } -> std::same_as<stop_iteration>;
} || requires(Consumer c, mutation m) {
{ c(std::move(m)) } -> std::same_as<future<stop_iteration>>;
};
template<typename T>
concept FlattenedConsumerV2 =
StreamedMutationConsumerV2<T> && requires(T obj, const dht::decorated_key& dk) {