PROSAGA码农传奇-运筹学-Reactive Extensions：将同步订阅转换为异步订阅

Reactive Extensions：将同步订阅转换为异步订阅

作者: 北极星微控
发布时间: 2024-07-25 01:21:17 (18天前)
转自：

<div class =“post-text”itemprop =“text”>
  
    我会远离
    
      方法1
    
    ，因为它“打破”了Rx。当你
     <code>
 await
 </code>
     在 - 的里面
     <code>
 Select
 </code>
     你正在做什么是同步操作员做异步工作。每当你想要做一些异步的事情时，把它放在一个
     <code>
 SelectMany
 </code>
    。
     <code>
 SelectMany
 </code>
     甚至接受一个
     <code>
 Task<T>
 </code>
     直。
  
  
    在
    
      方法2
    
     你正在包装
     <code>
 Task
 </code>
     在一个可观察的内部。我相信这非常相似
     <code>
 Observable.FromAsync()
 </code>
    。然而，它有点沉重的创造了一个
     <code>
 Task
 </code>
     然后将其转换为可观察的;你可以直接使用一个observable：
  
   <pre>
 <code>
 integers.Where(id => (id & 1) == 0)
 .SelectMany(id => Observable.Start(
 () => evenHandler.LRP(id, RandomDelay()),
 ThreadPoolScheduler.Default))
 .Subscribe();

integers.Where(id => (id & 1) == 1)
    .SelectMany(id => Observable.Start(
        () => oddHandler.LRP(id, RandomDelay()),
        ThreadPoolScheduler.Default))
    .Subscribe();

</code>
 </pre>
  
    这将创建一个返回a的observable
     <code>
 Unit
 </code>
     当内部工作完成时。我还指出它应该运行在
     <code>
 TaskPoolScheduler
 </code>
     这使它在一个内部运行
     <code>
 Task
 </code>
    。
  
</DIV>