java - 如何使用 RxJava 加载相关对象

Question

假设我也有那些类(class)

class Event {
  int id;
  String name;
  List<Integer> facilityIds;
  List<Facility> facilities; // Empty, the one I need to load
}

class Facility {
  int id;
  String name;
}

目标:打印出每个事件及其设施的名称。

约束:RxJava2，Facilities 只能一个接一个地加载(getFacility(facilityId))

来自Observable<Event> ，我无法找到加载设施并将它们设置回各自事件的方法。

基本上我在想这样的事情:

Observable<Event> events;
events
  .map(Event::getFacilityIds)
  .flatMap(Observable::fromIterable)
  .map(facilityId -> service.getFacility(facilityId))
  . // somehow get the event reference and
    // so some event.addFacility() or something similar

然后我就瞎了，无法找到将它们与事件联系起来的方法。我也考虑过使用 zip ，这可能是一个解决方案，但我没有找到一种方法来保留和事件引用，以便稍后为它们设置设施。

响应式(Reactive)的方法是什么？任何提示将不胜感激。

Answer 1

forEach 是什么？

events.forEach(event -> Observable.fromIterable(event.facilityIds)
            //or just .map(service::getFacility)
            .map(facilityId -> service.getFacility(facilityId)
            .forEach(facility -> event.facilities.add(facility)))

或者如果你想继续使用 doOnNext 而不是第一个流。
这将在前一个运算符(operator)的线程上同步执行。

如果您 getFacility 花费了宝贵的时间，您可以使用 flatMap 并行检索:

events.doOnNext(event -> Observable.fromIterable(event.facilityIds)
            .flatMap(facilityId -> 
                    Observable.fromCallable(() -> service.getFacility(facilityId))
                    .subscribeOn(Schedulers.computation()))
            .blockingSubsribe(facility -> event.facilities.add(facility)))

但在这种情况下，结果facilities 的顺序不能保证。