如何在 Silverlight Webclient 上执行 Rx Observable [英] how to do Rx Observable on Silverlight Webclient
本文介绍了如何在 Silverlight Webclient 上执行 Rx Observable的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!
问题描述
我想在我的 SL 应用中使用 Rx.我想在对我的网络服务器的 REST 请求上设置一个可观察的对象.我不知道如何连接 Observable.FromEvent 或 Observable.FromAsync.我最好的猜测是让 Webclient 完成触发一个事件,然后执行 Observable.FromEvent.有没有更好的方法?
I would like to use Rx in my SL app. I want to set up an observable on my REST requests to my webserver. I dont see how to wire up Observable.FromEvent or Observable.FromAsync. My best guess is to make Webclient completion fire an event and then do Observable.FromEvent. IS there a better way?
推荐答案
给你,这是在 Rx 中发出 Web 请求的最佳方式.
Here you go, this is the best way to make a web request in Rx.
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));
这篇关于如何在 Silverlight Webclient 上执行 Rx Observable的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持IT屋!
查看全文