如何正确计时观察值？

Question

使用事件中的可观察事件，我从Web服务下载最新的天气。我在家里的电话和模拟器上测试了这一点，它工作正常。我带着这个项目来工作，并在那里使用模拟器运行它。现在我不确定它是防火墙还是防火墙，但它似乎没有得到天气，它只是永远坐在那里，尝试。所以它让我想到，如果这种情况发生在手机上，那么我需要某种暂停，如果它不能在10-15秒内得到天气，那么就放弃。

下面是示例代码到目前为止

IObservable<IEvent<MyWeather.GetWeatherCompletedEventArgs>> observable = 
      Observable.FromEvent<MyWeather.GetWeatherCompletedEventArgs>(Global.WeatherService, "MyWeather.GetWeatherCompleted").Take(1); 

     observable.Subscribe(w => 
     { 

      if (w.EventArgs.Error == null) 
      { 
       // Do something with the weather 
      } 
     }); 

     Global.WeatherService.GetWeatherAsync(location); 

我怎么能在给定的时间后，得到这个时间安全撤离，如果没有是怎么回事？

Answer 1

Observable.Timeout怎么样？它应该做你想要的，或者？

observable.Subscribe(w => ...).Timeout(TimeSpan.FromSeconds(10)).Catch<>(...); 

Answer 2

您应该使用FromEventPattern（不FromEvent），所以我已经改变了你的观察的到：

var observable = 
     Observable 
     .FromEventPattern<MyWeather.GetWeatherCompletedEventArgs>(
      Global.WeatherService, 
      "MyWeather.GetWeatherCompleted") 
     .Take(1); 

那么你可以这样做：

var timeout = 
    Observable 
     .Timer(TimeSpan.FromSeconds(10.0)) 
     .Select(_ => (EventPattern<MyWeather.GetWeatherCompletedEventArgs>)null); 

observable 
    .Amb(timeout) 
    .Subscribe(w => 
    { 
     if (w != null && w.EventArgs.Error == null) 
     { 
      // Do something with the weather 
     } 
    }); 

Answer 3

使用闩锁在C＃

尝试

http://www.itdevspace.com/2009/05/c-latch-implementation.html