对 Observable (Subject) 进行单元测试

Question

我有一个 Repository ，其中有一个名为 Mutations 的公共 Subject ，可以订阅它。将可观察对象视为 Item 流更容易，其中源主要是套接字连接。

我使用诸如 Repository.Mutations.Subscribe(item => DoWhatever(item)); 之类的内容订阅流。

我有一个模拟数据源，我想将 Items 推送到该数据源以测试存储库中的 Stream/Observable 是否正在执行其工作。

我已经阅读了很多关于在 Rx 中使用 TestScheduler() 的内容，但是当我尝试创建单元测试以及这个调度程序如何使用我自己的代码发挥作用时，我完全迷失了。

诚然，我是 Rx 的初学者，但我希望有人能给我一两个提示。

Answer 1

如果您想要查看一个项目是否是由 Mutations 属性生成的，您可以像您所做的那样，但只需在测试代码中验证是否已调用实际的 subscribe 方法，即类似：

Item expectedItem = new Item();
Item actualItem = null;
Repository.Mutations.Subscribe(item => actualItem = item);
dataSource.PushItem(expectedItem);

Assert.AreSame(expectedItem, actualItem);