事件聚合器确认
EventAggregator confirmation
我想知道是否有一种方法可以在单一方法中从已发布的事件中获取结果。
我有一个 wcf 服务,这里是其中一种方法的实现:
public Result DisplayMessage(string message)
{
// some error handling
if(errorOccurred)
{
return new Result { IsError = true, ErrorMessage = "error occurred"}
}
eventAggregator.GetEvent<DisplayMessageEvent>().Publish(new DisplayMessageEventArg(message));
return new Result { IsError = false, ErrorMessage = String.Empty };
}
如您所见,我的 wcf 方法 returns 结果通知调用者是否发生错误。我可以在发布事件之前进行一些错误处理,但如果 DisplayMessageEvent 订阅方发生某些事情,我还想要 return 关于此的结果。通常我会做一些类似 DisplayMessageConfirmationEvent 的事情,然后从订阅者发送这个事件给发布者,但是如何在单一方法中做到这一点?
所以换句话说,基本上我想做的是发布事件,等待订阅者的结果,然后 return 将其发送给 WCF 调用者。有什么想法吗?
EventAggregator
仅用于即发即弃消息传递。可能您想使用其他类型的消息传递系统,它支持带结果的消息。
也就是说,您可以等待另一个事件,然后继续您的方法:
public Result DisplayMessage(string message)
{
// some error handling
if(errorOccurred)
{
return new Result { IsError = true, ErrorMessage = "error occurred"}
}
eventAggregator.GetEvent<DisplayMessageEvent>().Publish(new DisplayMessageEventArg(message));
var result = new TaskCompletionSource<Result>();
eventAggregator.GetEvent<DisplayMessageAnswerEvent>().Subscribe( x => result.SetResult( x ) );
return result.Result;
}
其中 DisplayMessageAnswerEvent
是 PubSubEvent<Result>
...
请注意,原始事件的订阅者必须始终发送答案,否则您将永远被卡住。
我想知道是否有一种方法可以在单一方法中从已发布的事件中获取结果。 我有一个 wcf 服务,这里是其中一种方法的实现:
public Result DisplayMessage(string message)
{
// some error handling
if(errorOccurred)
{
return new Result { IsError = true, ErrorMessage = "error occurred"}
}
eventAggregator.GetEvent<DisplayMessageEvent>().Publish(new DisplayMessageEventArg(message));
return new Result { IsError = false, ErrorMessage = String.Empty };
}
如您所见,我的 wcf 方法 returns 结果通知调用者是否发生错误。我可以在发布事件之前进行一些错误处理,但如果 DisplayMessageEvent 订阅方发生某些事情,我还想要 return 关于此的结果。通常我会做一些类似 DisplayMessageConfirmationEvent 的事情,然后从订阅者发送这个事件给发布者,但是如何在单一方法中做到这一点? 所以换句话说,基本上我想做的是发布事件,等待订阅者的结果,然后 return 将其发送给 WCF 调用者。有什么想法吗?
EventAggregator
仅用于即发即弃消息传递。可能您想使用其他类型的消息传递系统,它支持带结果的消息。
也就是说,您可以等待另一个事件,然后继续您的方法:
public Result DisplayMessage(string message)
{
// some error handling
if(errorOccurred)
{
return new Result { IsError = true, ErrorMessage = "error occurred"}
}
eventAggregator.GetEvent<DisplayMessageEvent>().Publish(new DisplayMessageEventArg(message));
var result = new TaskCompletionSource<Result>();
eventAggregator.GetEvent<DisplayMessageAnswerEvent>().Subscribe( x => result.SetResult( x ) );
return result.Result;
}
其中 DisplayMessageAnswerEvent
是 PubSubEvent<Result>
...
请注意,原始事件的订阅者必须始终发送答案,否则您将永远被卡住。