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

Commit 6ce0e4f

Browse files
committed
Expose the ProcessingDelay property, we'll need it
1 parent 7bd8c94 commit 6ce0e4f

File tree

2 files changed

+7
-0
lines changed

2 files changed

+7
-0
lines changed

src/GitHub.Exports.Reactive/Collections/ITrackingCollection.cs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -39,6 +39,10 @@ public interface ITrackingCollection<T> : IDisposable, IList<T> where T : ICopya
3939
void SetFilter(Func<T, int, IList<T>, bool> filter);
4040
void AddItem(T item);
4141
void RemoveItem(T item);
42+
/// <summary>
43+
/// How long to delay between processing incoming items
44+
/// </summary>
45+
TimeSpan ProcessingDelay { get; set; }
4246
event NotifyCollectionChangedEventHandler CollectionChanged;
4347
}
4448
}

src/UnitTests/GitHub.App/Models/ModelServiceTests.cs

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -437,6 +437,7 @@ public async Task NonExpiredIndexReturnsCache()
437437

438438
await modelService.InsertUser(new AccountCacheItem(user));
439439
var col = modelService.GetPullRequests(repo);
440+
col.ProcessingDelay = TimeSpan.Zero;
440441

441442
var count = 0;
442443
var evt = new ManualResetEvent(false);
@@ -498,6 +499,7 @@ public async Task ExpiredIndexReturnsLive()
498499

499500
await modelService.InsertUser(new AccountCacheItem(user));
500501
var col = modelService.GetPullRequests(repo);
502+
col.ProcessingDelay = TimeSpan.Zero;
501503

502504
var count = 0;
503505
var evt = new ManualResetEvent(false);
@@ -559,6 +561,7 @@ public async Task ExpiredIndexClearsItems()
559561

560562
await modelService.InsertUser(new AccountCacheItem(user));
561563
var col = modelService.GetPullRequests(repo);
564+
col.ProcessingDelay = TimeSpan.Zero;
562565

563566
var count = 0;
564567
var evt = new ManualResetEvent(false);

0 commit comments

Comments
 (0)