使用RxJava筛选项目列表

Question

如何使用RxJava过滤项目列表？

我有以下代码，LoadData()发出列表 :

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()
        .flatMap(chatrooms -> { return Observable.from(chatrooms); })
        .filter(chatroom -> { return !chatroom.getBlocked().equals(IS_BLOCKED); })
        .toList();

Answer 2

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

这应该会有帮助。