Skip to content

Commit dfe5889

Browse files
committed
Fixed a bug with RemoveIfEqual, ReplaceIfEqual with Hybrid Cache Client
1 parent fc232c7 commit dfe5889

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

src/Foundatio/Caching/HybridCacheClient.cs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -97,8 +97,8 @@ public async Task<bool> RemoveAsync(string key)
9797

9898
public async Task<bool> RemoveIfEqualAsync<T>(string key, T expected)
9999
{
100-
bool removed = await _distributedCache.RemoveAsync(key).AnyContext();
101-
await _localCache.RemoveAsync(key).AnyContext();
100+
bool removed = await _distributedCache.RemoveIfEqualAsync(key, expected).AnyContext();
101+
await _localCache.RemoveIfEqualAsync(key, expected).AnyContext();
102102
await _messageBus.PublishAsync(new InvalidateCache { CacheId = _cacheId, Keys = [key] }).AnyContext();
103103
return removed;
104104
}
@@ -192,8 +192,8 @@ public async Task<bool> ReplaceAsync<T>(string key, T value, TimeSpan? expiresIn
192192

193193
public async Task<bool> ReplaceIfEqualAsync<T>(string key, T value, T expected, TimeSpan? expiresIn = null)
194194
{
195-
await _localCache.ReplaceAsync(key, value, expiresIn).AnyContext();
196-
bool replaced = await _distributedCache.ReplaceAsync(key, value, expiresIn).AnyContext();
195+
await _localCache.ReplaceIfEqualAsync(key, value, expected, expiresIn).AnyContext();
196+
bool replaced = await _distributedCache.ReplaceIfEqualAsync(key, value, expected, expiresIn).AnyContext();
197197
await _messageBus.PublishAsync(new InvalidateCache { CacheId = _cacheId, Keys = [key] }).AnyContext();
198198
return replaced;
199199
}

0 commit comments

Comments
 (0)