flatmapIterableを使用したRxJava2マップ/ flatMap

Question

ここに私が達成しようとしていることがあります： Listの項目を含むmyResponseというAPIレスポンスがあります。私はflatMapIterableを通して各項目を繰り返して、うまくいきます。しかし、その前に、APIがエラーを返さないか、またはListサイズが0を超えていないかどうかチェックしたいと思います。これを達成することはできません。 は、ここで私はこれまで試してみましたどのようなコードです：

// This works & I am able to iterate through each item 
myApi.getData() 
.subscribeOn(Schedulers.newThread()) 
.observeOn(AndroidSchedulers.mainThread()) 
.flatMapIterable(response -> response.getData().getItems()) 
.subscribeWith(new DisposableObserver<Mobile>() { 
        @Override 
        public void onNext(@NonNull Item item) { 
         Log.e("TAG", "item is => " + item.getItemName()); 
        } 

        @Override 
        public void onError(@NonNull Throwable e) { 

        } 

        @Override 
        public void onComplete() { 
         Log.e("TAG", "processing completed"); 
        } 
       }); 

しかし、私はすべてのエラーをチェックするためにflatMapIterable前mapかflatmapを使用すべきかわかりません。私は成功せず、次のようなものをやっている：

はここ flatMapIterable上

myApi.getData() 
    .subscribeOn(Schedulers.newThread()) 
    .observeOn(AndroidSchedulers.mainThread()) 
    .map(response -> { 
     if(response.getStatus() == 200) { 
      List<Item> items = response.getData().getItems(); 
      if(items == null || items.size() < 1) 
        return Observable.error(new Throwable("No data!")); 

      return Observable.just(response); 
     } 

     return Observable.error(new Throwable(response.getData().getMsg())); 
    }) 
    .doOnError(Throwable::getMessage) 
    .flatMapIterable(response -> response.getData().getItems()); 

、私はエラーが（）のgetDataを解決することはできません取得します。私はそれがresponseをMyResponse.classと特定できないと信じているからです。私はここで立ち往生しています。私はRxJava2で私が望むものをどのように達成することができますか教えてください。

Answer 1

map(response -> {...})でObservableをMyResponseに作成したため、コンパイルされません。 map(response -> {...})をflatMap(response -> {...})に置き換えるか、flatMapIterableの前にflatMap(r -> r)を追加してください。