如何检测事件的所有订阅者是否已响应

Question

我现正调查地下铁路。我在星巴克样品的基础上写了一个简单的样本。

我有以下几件事：

    Define(() =>
    {
        Initially(
            When(ReportRequest)
                .Then((saga, message) => saga.ProcessReportRequest(message))
                .TransitionTo(WaitingForReportToComplete)
            );

        During(WaitingForReportToComplete, When(ReportComplete)
            .Then((saga, message) =>
                {
                    Console.WriteLine("Report Complete for '{0}'", saga.Name);
                    saga.CompleteReportRequest(message);
                })
                .Complete()
            );
    });

我遇到的问题是，我有ReportRequest事件的X订阅者，每个订阅者创建报告的一小部分。因此，要使报告被认为是完整的，所有订阅者都需要发出一个ReportComplete事件。目前，完成的第一个订阅者发出一个ReportComplete事件，然后佐贺也完成。

如何设置一个佐贺，以便它在完成之前等待所有X订阅者响应给定的消息？

Answer 1

我认为这是一个两步的解决方案：

• 首先，您需要“招募”您希望参与的所有订阅者。这可能是静态/共享信息，在传奇之外维护，这取决于您的场景。
• 只有当您从所有参选者那里收到“完成”时，您才能移动到完成状态。你可以指示传奇必须转移到另一个州。