🐛 Fix RemoveByPrefixAsync for Redis Caching Provider.

dotnetcore · Feb 2, 2018 · 4da5dfb · 4da5dfb
1 parent fdc615c
commit 4da5dfb
Showing 1 changed file with 9 additions and 3 deletions.
diff --git a/src/EasyCaching.Redis/DefaultRedisCachingProvider.cs b/src/EasyCaching.Redis/DefaultRedisCachingProvider.cs
@@ -296,7 +296,7 @@ public void RemoveByPrefix(string prefix)
         {
             ArgumentCheck.NotNullOrWhiteSpace(prefix, nameof(prefix));
 
-            this.HandlePrefix(prefix);
+            prefix = this.HandlePrefix(prefix);
 
             foreach (var server in _servers)
             {
@@ -361,9 +361,15 @@ private async Task HandleKeyDelWithTranAsync(IServer server, string prefix)
                 {
                     var tran = _cache.CreateTransaction();
 
-                    await tran.KeyDeleteAsync(keys.ToArray());
+                    Task delTask = tran.KeyDeleteAsync(keys.ToArray());
+
+                    Task execTask = tran.ExecuteAsync(CommandFlags.FireAndForget);
+
+                    await Task.WhenAll(delTask, execTask);
+
+                    //await tran.KeyDeleteAsync(keys.ToArray());
 
-                    await tran.ExecuteAsync(CommandFlags.FireAndForget);
+                    //await tran.ExecuteAsync(CommandFlags.FireAndForget);
                 }
             }
             while (count <= 0);