如何在 Silverlight Webclient 上执行 Rx Observable答案

【问题标题】：how to do Rx Observable on Silverlight Webclient如何在 Silverlight Webclient 上执行 Rx Observable
【发布时间】：2011-09-14 19:32:39
【问题描述】：

我想在我的 SL 应用程序中使用 Rx。我想在对我的网络服务器的 REST 请求上设置一个 observable。我看不到如何连接 Observable.FromEvent 或 Observable.FromAsync。我最好的猜测是让 Webclient 完成触发一个事件，然后执行 Observable.FromEvent。有没有更好的办法？

【问题讨论】：

+1 我想看看有人演示它的样子；）

标签： silverlight system.reactive

【解决方案1】：

给你，这是在 Rx 中发出 Web 请求的最佳方式。

public IObservable<WebResponse> MakeWebRequest(
        Uri uri, 
        Dictionary<string, string> headers = null, 
        string content = null,
        int retries = 3,
        TimeSpan? timeout = null)
{
    var request = Observable.Defer(() =>
    {
        var hwr = WebRequest.Create(uri);
        if (headers != null)
        {
            headers.ForEach(x => hwr.Headers[x.Key] = x.Value);
        }

        if (content == null)
        {
            return Observable.FromAsyncPattern<WebResponse>(hwr.BeginGetResponse, hwr.EndGetResponse)();
        }

        var buf = Encoding.UTF8.GetBytes(content);
        return Observable.FromAsyncPattern<Stream>(hwr.BeginGetRequestStream, hwr.EndGetRequestStream)()
            .SelectMany(x => Observable.FromAsyncPattern<byte[], int, int>(x.BeginWrite, x.EndWrite)(buf, 0, buf.Length))
            .SelectMany(_ => Observable.FromAsyncPattern<WebResponse>(hwr.BeginGetResponse, hwr.EndGetResponse)());
    });

    return request.Timeout(timeout ?? TimeSpan.FromSeconds(15)).Retry(retries);
}

使用方法如下：

MakeWebRequest(new Uri("http://www.google.com"))
    .Subscribe(
        x => Console.WriteLine("Response is {0}", x),
        ex => Console.WriteLine("Someone Set Us Up The Bomb: {0}", ex.Message));

【讨论】：

这需要一些时间来吸收！
不用担心实现，只要知道您传递信息以发出 Web 请求，并且您将获得一个 IObservable 最终将返回一个项目（回复）。在这种情况下，IObservable 代表一个“未来”，有点像 Task
你能否包括示例使用代码，包括错误处理？
那么大多数 Observable.Foo 返回 IObservable 但 OBservable.FromAsync 返回一个返回 IObservable 的 Func 的原因是什么？
因为它给了你一个 Func，每次你调用它都会发出一个新的请求，就像你调用 BeginXXXX 一样。它将开始/结束“翻译”成 Rx 友好的语法