From 9397fa1192984ce28c6ed6227e3711ef55cdf697 Mon Sep 17 00:00:00 2001 From: Raymond den Haan Date: Fri, 9 Feb 2024 13:49:15 +0100 Subject: [PATCH] Implemented FindMany --- .../Elsa.Dapper/Modules/Runtime/Stores/KeyValueStore.cs | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/src/modules/Elsa.Dapper/Modules/Runtime/Stores/KeyValueStore.cs b/src/modules/Elsa.Dapper/Modules/Runtime/Stores/KeyValueStore.cs index f0326274a..d7908d124 100644 --- a/src/modules/Elsa.Dapper/Modules/Runtime/Stores/KeyValueStore.cs +++ b/src/modules/Elsa.Dapper/Modules/Runtime/Stores/KeyValueStore.cs @@ -40,9 +40,10 @@ public class DapperKeyValueStore : IKeyValueStore return record == null ? null : Map(record); } - public Task> FindManyAsync(KeyValueFilter filter, CancellationToken cancellationToken) + public async Task> FindManyAsync(KeyValueFilter filter, CancellationToken cancellationToken) { - throw new NotImplementedException(); + var records = await _store.FindManyAsync(q => ApplyFilter(q, filter), cancellationToken); + return records.Select(Map); } ///