Range.cs 1.1 KB

12345678910111213141516171819202122232425262728293031323334
  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<int> Range(int start, int count)
  10. {
  11. var max = ((long)start) + count - 1;
  12. if (count < 0 || max > int.MaxValue)
  13. throw new ArgumentOutOfRangeException(nameof(count));
  14. throw new NotImplementedException();
  15. }
  16. public static IAsyncObservable<int> Range(int start, int count, IAsyncScheduler scheduler)
  17. {
  18. var max = ((long)start) + count - 1;
  19. if (count < 0 || max > int.MaxValue)
  20. throw new ArgumentOutOfRangeException(nameof(count));
  21. if (scheduler == null)
  22. throw new ArgumentNullException(nameof(scheduler));
  23. throw new NotImplementedException();
  24. }
  25. }
  26. }