Implemented FindMany

This commit is contained in:
Raymond den Haan 2024-02-09 13:49:15 +01:00
parent 442f8d07e8
commit 9397fa1192

View file

@ -40,9 +40,10 @@ public class DapperKeyValueStore : IKeyValueStore
return record == null ? null : Map(record);
}
public Task<IEnumerable<SerializedKeyValuePair>> FindManyAsync(KeyValueFilter filter, CancellationToken cancellationToken)
public async Task<IEnumerable<SerializedKeyValuePair>> FindManyAsync(KeyValueFilter filter, CancellationToken cancellationToken)
{
throw new NotImplementedException();
var records = await _store.FindManyAsync(q => ApplyFilter(q, filter), cancellationToken);
return records.Select(Map);
}
/// <inheritdoc />