監視可能なアイテムによって特定の量のアイテムがエミュレートされた後でアクションをトリガーする

Question

RxJavaが新しく、フローのカスタマイズに問題があります。ユースケースはこちらです：

私は画像のグリッドや画像の合計金額が表示されますTextViewとフッターを表示するGridLayoutManagerとRecyclerViewを持っています。文脈に入れるために、私はユーザが15枚の画像を持つことができます。TextViewは「15枚の画像」と言いますが、グリッドは4枚しか表示されません（「プレビュー」と理解してください）。さて、私が作成したObservableのonComplete()に、これらの画像を表示するために、私はadapter.notifyDatasetChanged()と呼ぶでしょう。しかし、その画像が表示されるのを待つことは無意味です。リストがあれば、200枚の画像が表示されます。リストから4枚の画像が出力されるとすぐにアダプターに通知したいと思います。私の観察できるが、そのように作成されます。

Observable.just(user.getUserId()) 
      .subscribeOn(Schedulers.io()) 
      .map(this::getImageList) 
      .flatMap(images -> Observable.fromIterable(images) 
       .map(image -> image)) 
      .observeOn(AndroidSchedulers.mainThread()); 

はそうした、その後、 images.size == 200あれば、それは（私はここでは正しいよ願っています）200回通知されますので、私は、 Observer.onNext()にアダプタを通知することはできません。 Observer.onComplete()でそれを行うことはできません。アダプタが通知される前に、200の模範的な画像のすべてが放出されるのを待つので、私はそれを行うこともできません。リストから4つのアイテムが放出されたときにそのフローを傍受し、（アダプタに通知する）どのようにして残りを放出し続けることができますか？4つだけで完了せずに、総イメージ量で適切なフッターテキストを表示できますイメージ？

UPDATE - この質問の範囲外の目的のために、私は観察可能な完了後に画像の完全なリストが必要です。私はそれらのうちの4つを表示し、TextViewを検索された画像の総量で更新し、検索された全画像のリストを保存したい。

Answer 1

flatMapのコードを変更しても、画像リストにアクセスしてサイズを取得できます。

Observable.just(user.getUserId()) 
     .subscribeOn(Schedulers.io()) 
     .map(this::getImageList) 
     .flatMap(images -> { 
       // you can access images size here, update footer 
       footer.setText(images.size() + " images"); 
       // pass full list of images to your view, i.e like this 
       view.setImages(images); 
       return Observable.fromIterable(images) 
      }) 
      .take(4) 
      .observeOn(AndroidSchedulers.mainThread()) 
      .subscribe(image -> { 
           // add image to grid 
           }, 
         error -> { 
           // handle error 
           } 
         () -> { 
           // four images were emitted, emission complete 
           adapter.notifyDatasetChanged(); 
           });