RxJava toMultiMap无法使用房间数据库查询

Question

我正在尝试获取消息的地图，作者id键如下：

Map<Long, Collection<Message>>

这是我尝试过的：

messageViewModel.getAll()
                    .flatMap(Flowable::fromIterable)
                    .toMultimap(Message::getAuthorId)
                    .subscribeOn(Schedulers.io())
                    .observeOn(AndroidSchedulers.mainThread())
                    .subscribe(this::onSuccess);

private void onSuccess(Map<Long, Collection<Message>> longCollectionMap) {
    Collection<Message> messages = longCollectionMap.get(0);
}

MessageViewModel.getAll（）方法返回：

Flowable<List<Message>>

然后我将其转换为一个可流动的流（Flowable：：fromIterable），这样它可以一次发出一个项目，而不是整个列表，然后我使用“toMultiMap”进行映射

on成功方法从不被调用，我不知道这里出了什么问题。如果我不使用toMultiMap（并对代码进行相应的修改）它是有效的，所以问题一定是toMultiMap方法。

但当我尝试这个时：

List<String> list = Arrays.asList("1", "2", "3");
Flowable.fromIterable(list)
                    .toMultimap(String::length)
                    .subscribeOn(Schedulers.io())
                    .observeOn(AndroidSchedulers.mainThread())
                    .subscribe(this::onSuccess);

 private void onSuccess(Map<Integer,Collection<String>> integerCollectionMap) {
    Collection<String> strings = integerCollectionMap.get(1);
}

这有效！唯一的区别是这个不调用房间数据库来获取可迭代的项目。

文件还说明：

请注意，此运算符要求上游向{@code on完成}发出信号以发出累积映射。

这让我很困惑。因为Flowable类没有一个以onComplete作为参数的subscribe方法，也没有在我上面展示的第二个案例中使用它，但它仍然有效。

请帮帮我，这快把我逼疯了。

Answer 1

您还可以使用：

Map<Long, Collection<Message>> myMap = messageViewModel.getAll()
    .flatMap(message ->
        Observable.fromIterable(message)
            .toMultimap(Message::getAuthorId)
            .toObservable());

Answer 2

我为任何遇到相同或类似问题的人找到了解决方案。

首先，我必须调试看看映射是否真的完成了。为此，我只是从toMultiMap方法开始调试它。然后我发现映射实际上已经完成了，所以问题是结果没有返回。

通过阅读更多关于RxJava的信息，我了解了问题的原因。第一次通话：

messageViewModel.getAll()

正在回归

Flowable<List<Message>>

这意味着这个源将发出0到n个元素，在这种情况下是消息的“列表”。事实上，它发送了Message列表，然后完成了映射。但它没有返回任何东西，因为它正在等待更多的“列表”从源中出现。

您必须记住，Flowable或Watable可能会发出无限的元素。与执行Flowable.fromIterable的区别在于fromIterable将停止，或者在发出作为参数传递的迭代的最后一个元素后发出流结束的信号，这意味着方法调用序列的其余部分不会等待更多元素的到来，结果将被返回。

因此，解决方案是将消息ViewModel.getAll（）的返回类型更改为：

Single<List<Message>>

因此，现在它要么发出1项消息列表，要么发出一个错误。因此，在发出一个元素后，将不再出现任何元素，链上的其他方法将执行并返回值。

但是“toMultiMap”方法不适用于“单”，在单类上没有这样的东西。所以你必须将它转换为可流动的，所以我这样做了：

.flatMapPublisher(Flowable::fromIterable)

因此，最终代码是这样结束的：

messageViewModel.getAll() //Returns Single<List<Message>>
                .flatMapPublisher(Flowable::fromIterable) // Creates a flowable from List<Message>
                .toMultimap(Message::getAuthorId)
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(this::onSuccess);

非常好且干净的代码，理解反应式方法的工作原理需要一些时间，但绝对值得。希望有人觉得这有用。