Rx ForkJoin 不适用于自定义事件

Question

我有一些自定义事件参数：

AutoOccurPerformedEventArgs : EventArgs

并且在 2 个单独的位置引发了具有这些事件参数的相同事件我正在尝试使用反应式扩展来分叉加入这些然后订阅

var events = new[]
                        {
                            Observable.FromEvent<AutoOccurPerformedEventArgs>(viewModel1, "AutoOccurActionPerformed"),
                            Observable.FromEvent<AutoOccurPerformedEventArgs>(viewModel2, "AutoOccurActionPerformed"),
                        };
events.ForkJoin().Subscribe(op => IsUpdatedByAutoOccur = op.Any(observedItem => observedItem.EventArgs.IsUpdatedByAutoOccur));

我在订阅中的匿名委托永远不会被调用。不会引发异常，只是永远不会调用委托。

但是，如果我在没有 ForkJoin 的情况下单独订阅每个事件，则事件会得到正确处理（尽管是单独的）

Observable.FromEvent<AutoOccurPerformedEventArgs>(viewModel1, "AutoOccurActionPerformed")
                .Subscribe(o => IsUpdatedByAutoOccur = o.EventArgs.IsUpdatedByAutoOccur ? true : IsUpdatedByAutoOccur);

Observable.FromEvent<AutoOccurPerformedEventArgs>(viewModel2, "AutoOccurActionPerformed")
                .Subscribe(o => IsUpdatedByAutoOccur = o.EventArgs.IsUpdatedByAutoOccur ? true : IsUpdatedByAutoOccur);

关于为什么 ForkJoin 不起作用的任何想法？

Answer 1

查看有关ForkJoin 方法的智能感知帮助。尽管有拼写错误，但它说：

并行运行两个可观察序列并组合它们的最后一个元素。

由于您正在对事件执行ForkJoin，因此您永远不会得到结果，因为这些类型的可观察对象永远不会完成。

您可能想使用Merge 或CombineLatest 来实现您想要的，但由于您没有描述您的意图，我无法给出更好的建议。