Timer.cs 2.2 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455
  1. // Licensed to the .NET Foundation under one or more agreements.
  2. // The .NET Foundation licenses this file to you under the Apache 2.0 License.
  3. // See the LICENSE file in the project root for more information.
  4. using System.Reactive.Concurrency;
  5. namespace System.Reactive.Linq
  6. {
  7. partial class AsyncObservable
  8. {
  9. public static IAsyncObservable<long> Timer(TimeSpan dueTime) => Timer(dueTime, TaskPoolAsyncScheduler.Default);
  10. public static IAsyncObservable<long> Timer(TimeSpan dueTime, IAsyncScheduler scheduler)
  11. {
  12. if (scheduler == null)
  13. throw new ArgumentNullException(nameof(scheduler));
  14. throw new NotImplementedException();
  15. }
  16. public static IAsyncObservable<long> Timer(DateTimeOffset dueTime) => Timer(dueTime, TaskPoolAsyncScheduler.Default);
  17. public static IAsyncObservable<long> Timer(DateTimeOffset dueTime, IAsyncScheduler scheduler)
  18. {
  19. if (scheduler == null)
  20. throw new ArgumentNullException(nameof(scheduler));
  21. throw new NotImplementedException();
  22. }
  23. public static IAsyncObservable<long> Timer(TimeSpan dueTime, TimeSpan period) => Timer(dueTime, period, TaskPoolAsyncScheduler.Default);
  24. public static IAsyncObservable<long> Timer(TimeSpan dueTime, TimeSpan period, IAsyncScheduler scheduler)
  25. {
  26. if (period < TimeSpan.Zero)
  27. throw new ArgumentOutOfRangeException(nameof(period));
  28. if (scheduler == null)
  29. throw new ArgumentNullException(nameof(scheduler));
  30. throw new NotImplementedException();
  31. }
  32. public static IAsyncObservable<long> Timer(DateTimeOffset dueTime, TimeSpan period) => Timer(dueTime, period, TaskPoolAsyncScheduler.Default);
  33. public static IAsyncObservable<long> Timer(DateTimeOffset dueTime, TimeSpan period, IAsyncScheduler scheduler)
  34. {
  35. if (period < TimeSpan.Zero)
  36. throw new ArgumentOutOfRangeException(nameof(period));
  37. if (scheduler == null)
  38. throw new ArgumentNullException(nameof(scheduler));
  39. throw new NotImplementedException();
  40. }
  41. }
  42. }