0

我正在尝试使用 Rx 在 Windows Phone 7.5 上为 linq-to-sql 编写异步 DataContext。我的想法是在DataContext中定义一个方法：

IObservable<List<Fact>> GetFacts(Func<MyDataContext, IQueryable<Fact>> selector)
    {
        var selectFacts = Observable.FromAsyncPattern<MyDataContext, IQueryable<Fact>>(selector.BeginInvoke, selector.EndInvoke);
        return selectFacts(db).Select((query) => query.ToList());// db variable is MyDataContext instance, and is not null during the call or later
    }

然后应该从客户端代码调用此方法，如下所示：

var q = GetFacts((database) => from item in database.Facts select item)
    .ObserveOnDispatcher()
    .Do((facts) => MessageBox.Show(facts.Count.ToString()))
    .Subscribe();

我面临的问题很奇怪。当from item in database.Facts select item实际调用客户端选择器 ( )时，database其上下文中的参数为空！因此，我显然得到了 NullReferenceException。但是当selectFacts被调用时，该db值是非空的，并且指向正确的实例。

这个事实有什么解释吗？如何克服它？

提前致谢。

4

1 回答 1

0

我认为你正在以一种非常奇怪的方式解决这个问题。如果你想在后台运行代码并让它返回一个IObservable<T>（如任务），你应该使用Observable.Start：

IObservable<List<Fact>> factsFuture = Observable.Start(
    () => selectFacts(db).Select(query).ToList(), 
    Scheduler.ThreadPoolScheduler);
于 2012-12-16T20:39:36.430 回答