使用 Web 客户端接收参数异常

Question

我正在使用反应式扩展，以便使用 Windows Phone 上的 WebClient 轻松下载网页。 当我运行以下代码时，我在 Subscribe 调用中收到 ArgumentExceptoin。

参数名称：{0}

参数名称：类型

public IObservable<DownloadStringCompletedEventArgs> StartRequest(string uri)
    {

        var _browser = new WebClient();
        var obs = Observable.FromEvent<DownloadStringCompletedEventHandler,
            DownloadStringCompletedEventArgs>(

                h => _browser.DownloadStringCompleted += h,
                h => _browser.DownloadStringCompleted -= h)
            .Where(e => !e.Cancelled)
            .Retry(3)
            .SelectMany(
                e => (e.Error == null && !string.IsNullOrEmpty(e.Result))
                         ? Observable.Return(e)
                         : Observable.Throw<DownloadStringCompletedEventArgs>(e.Error))
            .Take(1);



        _browser.DownloadStringAsync(new Uri(uri));

        return obs;
    }

 var obs = StartRequest("http://www.google.com");

        obs.Subscribe(
            x => Console.WriteLine(x.Result)

            );

Answer 1

您的问题是您使用的是 FromEvent 扩展，而不是 FromEventPattern 扩展。

前者适用于非标准事件，后者适用于遵循“sender/eventargs”模式的事件。

也就是说，您的可观察值仍然存在一些问题。

• WebClient 的实例永远不会被释放。你应该做
  当然会发生这种情况，但因为你正在使用可观察的你需要
  使用 Using 扩展方法。

• 在 Take(1) 之前放置 Where 可能意味着您的可观察值
  永远不会结束。

• 重试也不会为您做正确的事情。如果
  “DownloadStringCompleted” observable 有错误然后重试
  将重新附加到事件，但事件将永远不会返回新的
  值，因为您不会再次调用 DownloadStringAsync。

您想要对这种可观察量做的是让它在每次新观察者订阅时重新执行网络调用，但是，当共享订阅时（例如，如果可观察量已发布），那么您不希望网络调用重新执行。你有点想鱼与熊掌兼得。

操作方法如下：

public IObservable<string> CreateDownloadStringObservable(string uri)
{
    return Observable.Create<string>(o =>
    {
        var result = new ReplaySubject<string>();
        var inner = Observable.Using(() => new WebClient(), wc =>
        {
            var obs = Observable
                .FromEventPattern<
                    DownloadStringCompletedEventHandler,
                    DownloadStringCompletedEventArgs>(
                        h => wc.DownloadStringCompleted += h,
                        h => wc.DownloadStringCompleted -= h)
                .Take(1);
            wc.DownloadStringAsync(new Uri(uri));
            return obs;
        }).Subscribe(ep =>
        {
            if (ep.EventArgs.Cancelled)
            {
                result.OnCompleted();
            }
            else
            {
                if (ep.EventArgs.Error != null)
                {
                    result.OnError(ep.EventArgs.Error);
                }
                else
                {
                    result.OnNext(ep.EventArgs.Result);
                    result.OnCompleted();
                }
            }
        }, ex =>
        {
            result.OnError(ex);
        });
        return new CompositeDisposable(inner, result.Subscribe(o));
    });
}

现在您可以这样调用它：

IObservable<string> obs =
    CreateDownloadStringObservable("http://www.google.com")
        .Retry(3);

请注意，Retry 现在位于它应该所属的请求方法之外（除非您添加 retry 参数）到方法调用）。

Answer 2

您不能将 Retry 与 FromEvent 结合使用，因为 FromEvent 是一个热门可观察对象 - 您只会获得 3 次相同的结果。修复现有代码的最简单方法是通过 Observable.Defer：

string uri = "http://www.whatever.com";

var webClient = Observable.Defer(() => {
    var browser = new WebClient();
    var ret =  Observable.FromEvent<DownloadStringCompletedEventHandler, DownloadStringCompletedEventArgs>(
        h => _browser.DownloadStringCompleted += h,
        h => _browser.DownloadStringCompleted -= h);

    browser.DownloadStringAsync(new Uri(uri));
    return ret;
});

webClient
    .Timeout(TimeSpan.FromSeconds(15))
    .Retry(3);

Defer 意味着不是立即创建 WebClient，而是为每个 Subscribe() 的 Observable 的人创建它，这是重试所需的。