How to call back async function from Rx Subscribe?

by

Ana Betts’ answer works in most scenarios, but if you want to block the stream while waiting for the async function to finish you need something like this:

Observable.Interval(TimeSpan.FromSeconds(1))
          .Select(l => Observable.FromAsync(asyncMethod))
          .Concat()
          .Subscribe();

Or:

Observable.Interval(TimeSpan.FromSeconds(1))
          .Select(_ => Observable.Defer(() => asyncMethod().ToObservable()))
          .Concat()
          .Subscribe();

More Related Contents:

  1. How can I implement an exhaustMap handler in Rx.Net?
  2. Good introduction to the .NET Reactive Framework [closed]
  3. What’s a good way to run periodic tasks using Rx, with a single concurrent execution restriction?
  4. Pause and Resume Subscription on cold IObservable
  5. Can’t specify the ‘async’ modifier on the ‘Main’ method of a console app
  6. If async-await doesn’t create any additional threads, then how does it make applications responsive?
  7. How to use HttpWebRequest (.NET) asynchronously?
  8. Await on a completed task same as task.Result?
  9. Async/await with/without awaiting (fire and forget)
  10. Implement C# Generic Timeout
  11. When should I use Async Controllers in ASP.NET MVC?
  12. What is AsyncCallback?
  13. Accessing UI Control from BackgroundWorker Thread
  14. Asynchronous Task.WhenAll with timeout
  15. Async call with await in HttpClient never returns
  16. Async and await – difference between console, Windows Forms and ASP.NET
  17. How to read to end process output asynchronously in C#?
  18. Do the new C# 5.0 ‘async’ and ‘await’ keywords use multiple cores?
  19. Await in catch block
  20. Factory for IAsyncEnumerable or IAsyncEnumerator
  21. Converting async/await to Task.ContinueWith
  22. How to Async Files.ReadAllLines and await for results?
  23. I thought await continued on the same thread as the caller, but it seems not to
  24. Is it possible to get successful results from a Task.WhenAll when one of the tasks fails? [duplicate]
  25. What is the difference between .Wait() vs .GetAwaiter().GetResult()?
  26. BeginInvoke not supported on .NET core? (PlatformNotSupported exception)
  27. Await and SynchronizationContext in a managed component hosted by an unmanaged app
  28. C# Async Serial Port Read
  29. How to implement Task.WhenAny() with a predicate
  30. How do I Async download multiple files using webclient, but one at a time?

Leave a Comment