|
|
@@ -597,7 +597,7 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
//
|
|
|
// Separate method to avoid closure in synchronous completion case.
|
|
|
//
|
|
|
- task.ContinueWith(t => OnCompletedTask(value, t), _cancel.Token);
|
|
|
+ task.ContinueWithState((t, tuple) => tuple.@this.OnCompletedTask(tuple.value, t), (@this: this, value), _cancel.Token);
|
|
|
}
|
|
|
|
|
|
private void OnCompletedTask(TSource value, Task<TCollection> task)
|
|
|
@@ -758,7 +758,7 @@ namespace System.Reactive.Linq.ObservableImpl
|
|
|
//
|
|
|
// Separate method to avoid closure in synchronous completion case.
|
|
|
//
|
|
|
- task.ContinueWith(t => OnCompletedTask(value, index, t), _cancel.Token);
|
|
|
+ task.ContinueWithState((t, tuple) => tuple.@this.OnCompletedTask(tuple.value, tuple.index, t), (@this: this, value, index), _cancel.Token);
|
|
|
}
|
|
|
|
|
|
private void OnCompletedTask(TSource value, int index, Task<TCollection> task)
|