IHttpAsyncHandler和IObservable web請求

在異步處理程序中我從webrequest中創建一個IObservable，它返回一個重定向字符串。IHttpAsyncHandler和IObservable web請求

我訂閱了那個observable並調用了AsyncResult.CompleteCall（），但我不得不使用Thread.Sleep（100）來獲得它的執行。而且每次都不行。我很確定這是不正確的。你能否照亮一些光。謝謝！

public IAsyncResult BeginProcessRequest(HttpContext context, AsyncCallback cb, object state) 
    { 
     _context = context; 
     _ar = new AsyncResult(cb, state); 

     _tweet = context.Request["tweet"]; 
     string url = context.Request["url"]; 

     if(String.IsNullOrEmpty(_tweet) || String.IsNullOrEmpty(url)) 
     { 
      DisplayError("<h2>Tweet or url cannot be empty</h2>"); 
      return _ar; 
     } 

     _oAuth = new oAuthTwitterRx(); 
     using (_oAuth.AuthorizationLinkGet().Subscribe(p => 
     { 
      _context.Response.Redirect(p); 
      _ar.CompleteCall(); 
     }, 
       exception => DisplayError("<h2>Unable to connect to twitter, please try again</h2>") 
       )) 


     return _ar; 
    } 

public class AsyncResult : IAsyncResult 
{ 
    private AsyncCallback _cb; 
    private object _state; 
    private ManualResetEvent _event; 
    private bool _completed = false; 
    private object _lock = new object(); 

    public AsyncResult(AsyncCallback cb, object state) 
    { 
     _cb = cb; 
     _state = state; 
    } 

    public Object AsyncState 
    { 
     get { return _state; } 
    } 

    public bool CompletedSynchronously 
    { 
     get { return false; } 
    } 

    public bool IsCompleted 
    { 
     get { return _completed; } 
    } 

    public WaitHandle AsyncWaitHandle 
    { 
     get 
     { 
      lock (_lock) 
      { 
       if (_event == null) 
        _event = new ManualResetEvent(IsCompleted); 
       return _event; 
      } 
     } 
    } 

    public void CompleteCall() 
    { 
     lock (_lock) 
     { 
      _completed = true; 
      if (_event != null) 
       _event.Set(); 
     } 

     if (_cb != null) 
      _cb(this); 
    } 
}

來源

2010-04-07 Sergey

IHttpAsyncHandler和IObservable web請求

回答

相關問題