|
|
@ -62,7 +62,7 @@ public abstract class EntityCacheClient<TEntity, TPrimaryKey> : StatefulCacheCli
|
|
|
|
|
|
|
|
|
|
|
|
try
|
|
|
|
try
|
|
|
|
{
|
|
|
|
{
|
|
|
|
if (OnInvalidating(ctx, id) is TEntity entity && entity is IPrimaryKey<TPrimaryKey> pk)
|
|
|
|
if ((await OnInvalidating(ctx, id)) is TEntity entity && entity is IPrimaryKey<TPrimaryKey> pk)
|
|
|
|
Set(pk.Id, entity, TimeSpan.Zero);
|
|
|
|
Set(pk.Id, entity, TimeSpan.Zero);
|
|
|
|
|
|
|
|
|
|
|
|
if (transaction is not null)
|
|
|
|
if (transaction is not null)
|
|
|
@ -82,10 +82,6 @@ public abstract class EntityCacheClient<TEntity, TPrimaryKey> : StatefulCacheCli
|
|
|
|
if (context.GetService<IStorageProvider>() is not IStorageProvider provider)
|
|
|
|
if (context.GetService<IStorageProvider>() is not IStorageProvider provider)
|
|
|
|
return default;
|
|
|
|
return default;
|
|
|
|
|
|
|
|
|
|
|
|
var entities = await provider.Open<TEntity>().AsEntities();
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
var entity = entities.FirstOrDefault(e => e.Id.Equals(id));
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
return await (from dc in provider.Open<TEntity>()
|
|
|
|
return await (from dc in provider.Open<TEntity>()
|
|
|
|
where TypeComparer.Compare(dc.Id, id)
|
|
|
|
where TypeComparer.Compare(dc.Id, id)
|
|
|
|
select dc).AsEntity();
|
|
|
|
select dc).AsEntity();
|
|
|
|