From 7d1f8f228bb8476d3cda4aaa6db21f3635637c08 Mon Sep 17 00:00:00 2001
From: Ogoun <ogoun@users.noreply.github.com>
Date: Sun, 23 Jul 2023 18:26:23 +0300
Subject: [PATCH] IterateKeyBacket fix

---
 .../Interfaces/IStorePartitionAccessor.cs                 | 2 +-
 .../PartitionStorage/Partition/StorePartitionAccessor.cs  | 4 ++--
 ZeroLevel/ZeroLevel.csproj                                | 8 ++++----
 3 files changed, 7 insertions(+), 7 deletions(-)

diff --git a/ZeroLevel/Services/PartitionStorage/Interfaces/IStorePartitionAccessor.cs b/ZeroLevel/Services/PartitionStorage/Interfaces/IStorePartitionAccessor.cs
index 870aaff..6d0574a 100644
--- a/ZeroLevel/Services/PartitionStorage/Interfaces/IStorePartitionAccessor.cs
+++ b/ZeroLevel/Services/PartitionStorage/Interfaces/IStorePartitionAccessor.cs
@@ -33,7 +33,7 @@ namespace ZeroLevel.Services.PartitionStorage
         /// <summary>
         /// Iterating over all recorded data of the file with the specified key
         /// </summary>
-        Task IterateKeyBacket(TKey key, Action<TKey, TValue> kvHandler);
+        IAsyncEnumerable<KV<TKey, TValue>> IterateKeyBacket(TKey key);
         /// <summary>
         /// Deleting the specified key and associated data
         /// </summary>
diff --git a/ZeroLevel/Services/PartitionStorage/Partition/StorePartitionAccessor.cs b/ZeroLevel/Services/PartitionStorage/Partition/StorePartitionAccessor.cs
index 94841b1..1a8b49b 100644
--- a/ZeroLevel/Services/PartitionStorage/Partition/StorePartitionAccessor.cs
+++ b/ZeroLevel/Services/PartitionStorage/Partition/StorePartitionAccessor.cs
@@ -134,7 +134,7 @@ namespace ZeroLevel.Services.PartitionStorage
                 }
             }
         }
-        public async Task IterateKeyBacket(TKey key, Action<TKey, TValue> kvHandler)
+        public async IAsyncEnumerable<KV<TKey, TValue>> IterateKeyBacket(TKey key)
         {
             var fileName = _options.GetFileName(key, _info);
             var filePath = Path.Combine(_catalog, fileName);
@@ -153,7 +153,7 @@ namespace ZeroLevel.Services.PartitionStorage
                             var vv = await Serializer.ValueDeserializer.Invoke(reader);
                             if (vv.Success == false) break;
 
-                            kvHandler.Invoke(kv.Value, vv.Value);
+                            yield return new KV<TKey, TValue>(kv.Value, vv.Value);
                         }
                     }
                 }
diff --git a/ZeroLevel/ZeroLevel.csproj b/ZeroLevel/ZeroLevel.csproj
index 20631e2..b23f9bd 100644
--- a/ZeroLevel/ZeroLevel.csproj
+++ b/ZeroLevel/ZeroLevel.csproj
@@ -6,16 +6,16 @@
 </Description>
     <Authors>ogoun</Authors>
     <Company>ogoun</Company>
-    <AssemblyVersion>3.4.0.4</AssemblyVersion>
-    <PackageReleaseNotes>KVDB, extend search method</PackageReleaseNotes>
+    <AssemblyVersion>3.4.0.5</AssemblyVersion>
+    <PackageReleaseNotes>KVDB</PackageReleaseNotes>
     <PackageProjectUrl>https://github.com/ogoun/Zero/wiki</PackageProjectUrl>
     <Copyright>Copyright Ogoun 2023</Copyright>
     <PackageLicenseUrl></PackageLicenseUrl>
     <PackageIconUrl></PackageIconUrl>
     <RepositoryUrl>https://github.com/ogoun/Zero</RepositoryUrl>
     <RepositoryType>git</RepositoryType>
-    <Version>3.4.0.4</Version>
-    <FileVersion>3.4.0.4</FileVersion>
+    <Version>3.4.0.5</Version>
+    <FileVersion>3.4.0.5</FileVersion>
     <Platforms>AnyCPU;x64;x86</Platforms>
     <PackageIcon>zero.png</PackageIcon>
     <DebugType>full</DebugType>