Androidでretrofitを使用してrxjava内のアイテムリストの各反復処理を処理する方法

Question

私はRxJavaプログラミングの初心者ですが、私は改造呼び出しから持っているリストの各繰り返しをどのように処理するかについて質問したいと思います。予定の

1. のGetリスト
2. 反復はそれぞれ任命し、
ここ

が私のコードでpatient_idと

は、予定のリストに戻って変換subservice_idを得る：基本的に私は何をしたいですこれまで

Observable<List<Appointment>> callAppointments = appointmentServiceRx.getService().getConfirmedAppointments(user_id); 
    callAppointments.subscribeOn(Schedulers.io()) 
      .observeOn(AndroidSchedulers.mainThread()) 
      .flatMapIterable(apps -> apps) 
      .concatMap(app -> getPatientById(app) 
        .doOnNext(this::addPatientNames) 
        .map(patient -> app) 
      ).concatMap(app -> getSubserviceById(app) 
        .doOnNext(this::addSubserviceNames) 
        .map(subservice -> app) 
      ).toList() 
      .subscribe(res -> doStuff(), 
        throwable -> showThrowable()); 

Answer 1

observeOn(AndroidSchedulers.mainThread())最初にコールすると、以降のすべての演算子がメインスレッド上で実行され、次にNetworkOnMainThreadExceptionがスローされます。

はsubscribe前の最後の点にこの呼び出しを移動してみてください：

// ... 
.observeOn(AndroidSchedulers.mainThread()) 
.subscribe(res -> doStuff(), 
    throwable -> showThrowable());