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 来实现您想要的，但由于您没有描述您的意图，我无法给出更好的建议。