1 files changed, 7 insertions, 0 deletions

diff --git a/common/query.h b/common/query.h
index fd79105..9030d7c 100644
--- a/common/query.h
+++ b/common/query.h
@@ -234,6 +234,13 @@ public:
             return *this;
         }
 
+        template <typename T>
+        Reduce &collect()
+        {
+            aggregators << Aggregator(QByteArray{T::name} + QByteArray{"Collected"}, Aggregator::Collect, T::name);
+            return *this;
+        }
+
         //Reduce on property
         QByteArray property;
         Selector selector;