Silverlight Webclient에서 Rx Observable을 수행하는 방법

Question

내 SL 응용 프로그램에서 Rx를 사용하고 싶습니다. 내 웹 서버에 내 REST 요청에 대한 관찰 가능을 설정하고 싶습니다. Observable.FromEvent 또는 Observable.FromAsync를 연결하는 방법을 알지 못합니다. 최선의 추측은 Webclient 완료가 이벤트를 시작한 다음 Observable.FromEvent를 수행하는 것입니다. 거기에 더 좋은 방법이 있습니까?

Answer 1

이제 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));