File tree Expand file tree Collapse file tree
src/ByteSync.Client/Services/TimeTracking
tests/ByteSync.Client.UnitTests/Services/TimeTracking Expand file tree Collapse file tree Original file line number Diff line number Diff line change 1- using System . Reactive . Linq ;
1+ using System . Reactive . Concurrency ;
2+ using System . Reactive . Linq ;
23using System . Reactive . Subjects ;
34using ByteSync . Business . Misc ;
45using ByteSync . Interfaces . Controls . TimeTracking ;
@@ -11,10 +12,12 @@ public class TimeTrackingComputer : ITimeTrackingComputer
1112 private readonly BehaviorSubject < bool > _isStarted ;
1213
1314 private readonly IDataTrackingStrategy _dataTrackingStrategy ;
15+ private readonly IScheduler _scheduler ;
1416
15- public TimeTrackingComputer ( IDataTrackingStrategy dataTrackingStrategy )
17+ public TimeTrackingComputer ( IDataTrackingStrategy dataTrackingStrategy , IScheduler ? scheduler = null )
1618 {
1719 _dataTrackingStrategy = dataTrackingStrategy ;
20+ _scheduler = scheduler ?? Scheduler . Default ;
1821
1922 _timeTrack = new BehaviorSubject < TimeTrack > ( new TimeTrack ( ) ) ;
2023 _isStarted = new BehaviorSubject < bool > ( false ) ;
@@ -49,7 +52,7 @@ public IObservable<TimeTrack> RemainingTime
4952 {
5053 if ( isStarted )
5154 {
52- return Observable . Interval ( TimeSpan . FromSeconds ( 1 ) ) ;
55+ return Observable . Interval ( TimeSpan . FromSeconds ( 1 ) , _scheduler ) ;
5356 }
5457 else
5558 {
You can’t perform that action at this time.
0 commit comments