Skip to content
This repository was archived by the owner on Jun 21, 2023. It is now read-only.

Commit a8d7b5b

Browse files
committed
Bulk delete from the db everything that's been deleted remotely
1 parent 350f833 commit a8d7b5b

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

src/GitHub.App/Extensions/AkavacheExtensions.cs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -197,6 +197,7 @@ static IObservable<T> GetAndFetchLatestFromIndex<T>(this IBlobCache This,
197197
.Finally(() =>
198198
{
199199
This.GetObjects<T>(index.OldKeys.Except(index.Keys))
200+
.Do(dict => This.InvalidateObjects<T>(dict.Keys))
200201
.SelectMany(dict => dict.Values)
201202
.Do(item => removedItemsCallback(item))
202203
.Subscribe();

0 commit comments

Comments
 (0)