【发布时间】:2012-05-09 17:20:11
【问题描述】:
我正在使用 RX 扩展和 WF4 来创建一个工作流,该工作流对可观察到的消息做出反应以推进工作流。为此,我引入了一个包含 IObservable 的对象(ModuleMessage 是我的抽象类。)我遇到的问题是 .Subscribe 无法识别其任何扩展方法,即用于 lambda 扩展/方法组的扩展方法。在下面的代码中,我有引用:
using System.Activities;
using System.Activities.Hosting;
using System.Collections.Generic;
using System.Reactive.Linq;
还有下面这行代码:
internal void AddModuleCallback(IModule module)
{
if (!addedCallback)
{
addedCallback = true;
module.Messages.Where(m => m is MemberLeftModuleMessage || m is MemberRemovedModuleMessage).Subscribe(m => this.OnMemberExit(m)); // This line errors
}
}
internal void OnMemberExit(ModuleMessage message)
{
// Gizmo was fired, resume the bookmark
this.instance.BeginResumeBookmark(
new Bookmark(ModuleVisit.BookmarkName),
message is MemberLeftModuleMessage,
r => this.instance.EndResumeBookmark(r),
null);
}
编译时错误:
Error 1 Cannot convert lambda expression to type 'System.IObserver<Components.Messages.ModuleMessage>' because it is not a delegate type <Removed>\WaitForModuleVisitExtension.cs 34 119 Components
请注意,此代码改编自一个示例,并没有按照我的喜好进行分解,我只是关心手头的问题。我不是 RX 或 WF4 的专业人士,但在同一解决方案的其他地方以这种方式使用了订阅。我已经通过 NuGet 将 RX 添加到这个项目中。
编辑:如果我用作方法组(而不是 lambda),则会出现以下错误:
Error 2 Argument 1: cannot convert from 'method group' to 'System.IObserver<Components.Messages.ModuleMessage>' <removed>\WaitForModuleVisitExtension.cs 34 119 Components
【问题讨论】:
-
您能分享您提到的示例的链接吗?这看起来很有趣。我一直认为 Observables 是不可序列化的,那么如何在需要随时支持持久性的工作流中使用它们呢?
-
这是很久以前的事了,我都不记得了。我想我在被其他闪亮的东西分心之前从来没有达到过这一点(这是一个个人项目)
标签: workflow-foundation-4 system.reactive nuget