Как правильно определить время наблюдения?

Question

Используя наблюдаемое событие, я загружаю последнюю погоду из веб-службы. Я тестировал это на телефоне и эмуляторе дома, и он отлично работает. Я привёл проект со мной на работу и запустил его с помощью эмулятора. Теперь я не уверен, что это брандмауэр или что-то, но, похоже, он не получает погоду, он просто сидит там навсегда, пытаясь. Поэтому мне казалось, что если это когда-нибудь случится на телефоне, мне нужен какой-то тайм-аут, потому что если он не сможет заставить погоду сказать 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