diff options
Diffstat (limited to 'Rx/NET/Source/System.Reactive.PlatformServices/Reactive/Concurrency/TaskPoolScheduler.cs')
-rw-r--r-- | Rx/NET/Source/System.Reactive.PlatformServices/Reactive/Concurrency/TaskPoolScheduler.cs | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/Rx/NET/Source/System.Reactive.PlatformServices/Reactive/Concurrency/TaskPoolScheduler.cs b/Rx/NET/Source/System.Reactive.PlatformServices/Reactive/Concurrency/TaskPoolScheduler.cs index a84588b..a27e7a6 100644 --- a/Rx/NET/Source/System.Reactive.PlatformServices/Reactive/Concurrency/TaskPoolScheduler.cs +++ b/Rx/NET/Source/System.Reactive.PlatformServices/Reactive/Concurrency/TaskPoolScheduler.cs @@ -111,7 +111,11 @@ namespace System.Reactive.Concurrency var ct = new CancellationDisposable(); d.Disposable = ct; +#if USE_TASKEX + TaskEx.Delay(dueTime, ct.Token).ContinueWith(_ => +#else Task.Delay(dueTime, ct.Token).ContinueWith(_ => +#endif { if (!d.IsDisposed) d.Disposable = action(this, state); @@ -190,7 +194,11 @@ namespace System.Reactive.Concurrency var moveNext = default(Action); moveNext = () => { +#if USE_TASKEX + TaskEx.Delay(period, cancel.Token).ContinueWith( +#else Task.Delay(period, cancel.Token).ContinueWith( +#endif _ => { moveNext(); |