PortableClass.cs 718 B

12345678910111213141516171819202122232425262728
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using System.Text;
  5. using System.Reactive;
  6. using System.Reactive.Linq;
  7. using System.Reactive.Concurrency;
  8. namespace PortableClassLibrary
  9. {
  10. public class PortableClass
  11. {
  12. public IObservable<long> CreateTimer(int numSamples, TimeSpan timespan)
  13. {
  14. var fromTime = DateTimeOffset.Now.Add(timespan);
  15. return Observable.Timer(fromTime, timespan)
  16. .Take(numSamples);
  17. }
  18. public IObservable<int> CreateList(IScheduler scheduler)
  19. {
  20. var values = new [] {1,2,5,7,8,324,4234,654654};
  21. return values.ToObservable(scheduler);
  22. }
  23. }
  24. }