主页 / 问题 / 939378
Accepted
elik
Asked:2020-02-01 14:42:25 +0000 UTC2020-02-01 14:42:25 +0000 UTC

如何从无限流中正确转换对象？

  • 772

我从数据库中获取数据，Flowable但是当我像这样转换它时

return getGoodsRepository()
                .getAllItems()
                .flatMapIterable(itemList ->itemList)
                .flatMap(item ->Flowable.just(getGoodsModelMapper().transformTo(item)))
                 .toList()
                .toFlowable();

那么数据没有进来，我想这是因为我在做什么toList

但是如何解决这个问题???因为没有toList我就无法制作大量的物体flatmapa

java

1 个回答

  1. Best Answer

    您不会发出onComplete事件，因为 链条以 开头Flowable，他自己不会抛出这个事件。结果，操作符.toList()永远不会被执行，因为 他 保留 收到 的 一切 , 直到 他 收到 一个 事件 才 放弃onComplete.

    您需要像这样使链复杂化：

    getGoodsRepository()
    .getAllItems()
    .flatMapSingle( items ->
        Flowable
                .fromIterable(items)
                .flatMap( item ->
                    Flowable.just(getGoodsModelMapper().transformTo(item)))
                )
                .toList()
    )

    这将起作用，因为 Flowable.fromIterable(items)将导致onComplete所有元素发射后，它toList()会起作用并且链会走得更远。

    • 1

相关问题