Updated replay subject

david-driscoll · david-driscoll · commit 0dae323cba9a · 2021-04-15T22:33:02.000-04:00
diff --git a/src/Protocol/Progress/PartialItemsRequestProgressObservable.cs b/src/Protocol/Progress/PartialItemsRequestProgressObservable.cs
@@ -36,7 +36,7 @@ Action onCompleteAction
         )
         {
             _serializer = serializer;
-            _dataSubject = new ReplaySubject<IEnumerable<TItem>>(int.MaxValue, Scheduler.Immediate);
+            _dataSubject = new ReplaySubject<IEnumerable<TItem>>(int.MaxValue);
             _disposable = new CompositeDisposable() { _dataSubject };
 
             _task = Observable.Create<TResult>(
diff --git a/src/Protocol/Progress/RequestProgressObservable.cs b/src/Protocol/Progress/RequestProgressObservable.cs
@@ -34,7 +34,7 @@ Action onCompleteAction
         )
         {
             _serializer = serializer;
-            _dataSubject = new ReplaySubject<TItem>(1, Scheduler.Immediate);
+            _dataSubject = new ReplaySubject<TItem>(1);
             _disposable = new CompositeDisposable() { _dataSubject };
 
             _task = Observable.Create<TResult>(

Original file line number	Diff line number	Diff line change
`@@ -36,7 +36,7 @@ Action onCompleteAction`
`36`	`36`	`)`
`37`	`37`	`{`
`38`	`38`	`_serializer = serializer;`
`39`		`- _dataSubject = new ReplaySubject<IEnumerable<TItem>>(int.MaxValue, Scheduler.Immediate);`
	`39`	`+ _dataSubject = new ReplaySubject<IEnumerable<TItem>>(int.MaxValue);`
`40`	`40`	`_disposable = new CompositeDisposable() { _dataSubject };`
`41`	`41`
`42`	`42`	`_task = Observable.Create<TResult>(`
Original file line number	Diff line number	Diff line change
`@@ -34,7 +34,7 @@ Action onCompleteAction`
`34`	`34`	`)`
`35`	`35`	`{`
`36`	`36`	`_serializer = serializer;`
`37`		`- _dataSubject = new ReplaySubject<TItem>(1, Scheduler.Immediate);`
	`37`	`+ _dataSubject = new ReplaySubject<TItem>(1);`
`38`	`38`	`_disposable = new CompositeDisposable() { _dataSubject };`
`39`	`39`
`40`	`40`	`_task = Observable.Create<TResult>(`