使用 Rx 调用 WCF 服务方法 Async 导致闭包问题

Question

我目前正在使用此代码调用 Web 服务来获取应用程序页面的数据。 一切都很好，直到我尝试连续调用此方法 10 次而不等待第一次调用完成。

这样做会导致我遇到闭包问题，并且我的所有结果都得到相同的结果对象。

以前有人在 Rx.Net 中遇到过这个问题吗？如果是的话，有人有想法或线索，以便我可以解决这个问题。

    public void GetPage(long pageId, Action<PageDTO> observer)
    {

        Observable.FromEvent<GetPageCompletedEventArgs>(
            handler => Service.GetPageCompleted += handler,
            handler => Service.GetPageCompleted -= handler)
            .Select(eventHandler => eventHandler.EventArgs.Result)
            .Take(1) // necessary to ensure the observable unsubscribes
            .ObserveOnDispatcher() // controls which thread the observer runs on;
            .Subscribe(observer, HandleError);

        Service.GetPageAsync(pageId);
    }

Answer 1

Service 总是同一个实例吗？如果是这样，您将遇到各种疯狂的情况，其中 GetPageCompleted 事件将由不同调用（具有不同参数）创建的 FromEvent 处理，这将解释为什么同时调用的所有方法的结果都相同。

您可以通过使用 Begin/End 方法来解决这个特定问题，但您仍然可能会遇到底层连接争用的问题。

public void GetPage(long pageId, Action<PageDTO> observer)
{
    Observable.FromAsyncPattern<long, PageDTO>(
            service.BeginGetAwards, service.EndGetAwards)(pageId)
        .ObserveOnDispatcher() // controls which thread the observer runs on;
        .Subscribe(observer, HandleError);
}