标签：system-reactive reactive-programming c

我有这个课：

public class TestService
{
     public IObservable<int> GetObservable(int max)
     {
         var subject = new Subject<int>();
         Task.Factory.StartNew(() =>
                               {
                                   for (int i = 0; i < max; i++)
                                   {
                                       subject.OnNext(i);
                                   }
                                   subject.OnCompleted();

                               });
         return subject;
     }
}

我也为此编写了一个测试方法：

[TestMethod]
public void TestServiceTest1()
{
   var testService = new TestService();
   var i = 0;
   var observable = testService.GetObservable(3);
   observable.Subscribe(_ =>
   {
      i++;
   });          
   observable.Wait();
   Assert.AreEqual(i, 3);
}

但是有时候我会收到错误消息：Sequence方法Wait()中不包含任何元素.

我建议在测试达到observable.Wait()行之前完成我的IObservable.
如何避免此错误？

解决方法:

在我看来,这段代码中的基本问题是IObservable代表如何观察事物的契约.

在这种情况下,GetObservable方法不仅返回合同,而且还立即执行工作(使用TPL).如果您认为可以多次订阅同一IObservable实例(这实际上是在示例代码中发生的,因为您是第一次使用Subscribe订阅,而另一个使用Wait订阅),则这没有任何意义.这个单一的区别是我学习Rx的最大绊脚石.

我将改为实现这样的方法(并避免完全使用Subject<&gt ;,因为它不是创建Observable的首选方式)：

public class TestService
{
     public IObservable<int> GetObservable(int max)
     {
         return Observable.Create<int>((IObserver<int> observer) =>
                               {
                                   for (int i = 0; i < max; i++)
                                   {
                                       observer.OnNext(i);
                                   }
                                   observer.OnCompleted();
                               });
     }
}

Observable.Create也有一些有趣的替代方法,它们提供了更大的灵活性.

标签：system-reactive,reactive-programming,c
来源： https://codeday.me/bug/20191031/1972068.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。