reactiveui - ReactiveUI 消息总线

Question

我正在测试 ReactiveUI，看起来很不错。

但是，我对 MessageBus 有点困惑。

示例代码：

var bus = new MessageBus();
int result = -1;

bus.Listen<int>().Subscribe(x => result = x);
bus.SendMessage(42);

它在调用 Assert 语句时确实有效，但在标准 WPF 应用程序中，结果值永远不会更新。这可能是由于调度程序的实现，但我还不太清楚。

欢迎任何提示。

Answer 1

结果最终会更新（与调用相同Dispatcher.BeginInvoke），而不是立即更新。默认情况下，RxUI 在单元测试运行器中以不同的方式安排事情，以便更容易编写单元测试——这就是为什么你会在单元测试运行器输出中看到该警告。

如果您要改为执行以下操作：

var bus = new MessageBus();

bus.Listen<int>().Subscribe(x => MessageBox.Show("The answer is " + x));
bus.SendMessage(42);

您将看到消息框（如果没有，那肯定是一个错误！）。

为什么 MessageBus 被延迟？它使编写异步代码变得更加容易，因为您现在可以从其他线程发送消息，而不会因为访问错误线程上的对象而看到 WPF 可怕的 InvalidOperationException。