RxJavaを使用したアイテムのフィルタリスト

Question

RxJavaでアイテムリストをフィルタリングするにはどうすればよいですか？

私は、次のコードを持っているとloadData()はList<Chatroom>発する：

repository.loadData() 
     .subscribe(chatrooms -> { 
      view.showData(chatrooms); 
      view.showEmptyState(chatrooms.size() == 0); 
     }, throwable -> Log.i("OnError", "onLoadChatrooms ", throwable))); 

と私はloadData()後にフィルタを適用したいです。次のコードスニペットで私の解決策を見ることができますが、もっと良い方法がありますか？

repository.loadData() 
     .map(chatrooms -> { 

      List<Chatroom> openChatrooms = new ArrayList<>(); 
      for (Chatroom chatroom: chatrooms){ 
       if (!chatroom.getBlocked().equals(IS_BLOCKED)) { 
        openChatrooms.add(chatroom); 
       } 
      } 
      return openChatrooms; 

     }) 
     .subscribe(chatrooms -> { 
      view.showData(chatrooms); 
      view.showEmptyState(chatrooms.size() == 0); 
     }, throwable -> Log.i("OnError", "onLoadChatrooms ", throwable))); 

Answer 1

loadData() 
    // Opther operations if any 
    .filter((chatroom -> { return !chatroom.getBlocked().equals(IS_BLOCKED);}) 
    .toList() 
    .subscribe(getObserver()); // implement your getObserver() method for observer. 

-

通常、私は次のように書きます。

Answer 2

あなたの解決策は、スタイルで「機能していない」場合は問題ありません。これは役立つはず

loadData() 
     .flatMap(chatrooms -> { return Observable.from(chatrooms); }) 
     .filter(chatroom -> { return !chatroom.getBlocked().equals(IS_BLOCKED); }) 
     .toList();