как сделать Rx Observable на Silverlight Webclient - PullRequest
Новая
       0

как сделать Rx Observable на Silverlight Webclient

3 голосов
/ 14 сентября 2011

Я хотел бы использовать Rx в моем приложении SL.Я хочу настроить наблюдаемый по моим запросам REST на мой веб-сервер.Я не вижу, как подключить Observable.FromEvent или Observable.FromAsync.Мое лучшее предположение - заставить завершение Webclient запустить событие, а затем выполнить Observable.FromEvent.Есть ли лучший способ?

1 Ответ

3 голосов
/ 15 сентября 2011

Вот, пожалуйста, это лучший способ сделать веб-запрос в 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));
...