Я пытаюсь понять правильные варианты использования Reactive Extensions (Rx). Примеры, которые продолжают появляться, — это события пользовательского интерфейса (перетаскивание, рисование) и предположения о том, что Rx подходит для асинхронных приложений/операций, таких как вызовы веб-службы.
Я работаю над приложением, в котором мне нужно написать крошечный клиентский API для службы REST. Мне нужно вызвать четыре конечных точки REST, три для получения справочных данных (аэропорты, авиакомпании и статусы), а четвертая — основная служба, которая предоставит вам время полета для заданного аэропорта.
Я создал классы, предоставляющие три службы справочных данных, и методы выглядят примерно так:
public Observable<IEnumerable<Airport>> GetAirports()
public Observable<IEnumerable<Airline>> GetAirlines()
public Observable<IEnumerable<Status>> GetStatuses()
public Observable<IEnumerable<Flights>> GetFlights(string airport)
В моем методе GetFlights я хочу, чтобы каждый рейс содержал ссылку на аэропорт, из которого он вылетает, и на авиакомпанию, выполняющую рейс. Для этого мне нужны данные из GetAirports и GetAirlines. Каждый аэропорт, авиакомпания и статус будут добавлены в словарь (то есть словарь), чтобы я мог легко установить ссылку при разборе каждого рейса.
flight.Airport = _airports[flightNode.Attribute("airport").Value]
flight.Airline = _airlines[flightNode.Attribute("airline").Value]
flight.Status = _statuses[flightNode.Attribute("status").Value]
Моя текущая реализация теперь выглядит так:
public IObservable<IEnumerable<Flight>> GetFlightsFrom(Airport fromAirport)
{
var airports = new AirportNamesService().GetAirports();
var airlines = new AirlineNamesService().GetAirlines();
var statuses = new StatusService().GetStautses();
var referenceData = airports
.ForkJoin(airlines, (allAirports, allAirlines) =>
{
Airports.AddRange(allAirports);
Airlines.AddRange(allAirlines);
return new Unit();
})
.ForkJoin(statuses, (nothing, allStatuses) =>
{
Statuses.AddRange(allStatuses);
return new Unit();
});
string url = string.Format(_serviceUrl, 1, 7, fromAirport.Code);
var flights = from data in referenceData
from flight in GetFlightsFrom(url)
select flight;
return flights;
}
private IObservable<IEnumerable<Flight>> GetFlightsFrom(string url)
{
return WebRequestFactory.GetData(new Uri(url), ParseFlightsXml);
}
Текущая реализация основана на ответе Сергея и использует ForkJoin для обеспечения последовательного выполнения и того, что я ссылаюсь на данные, загружаемые перед полетами. Эта реализация намного элегантнее, чем запуск события «ReferenceDataLoaded», как в моей предыдущей реализации.
