无法将io.reactivex.Flowable <io.reactivex.Maybe>分配给: io.reactivex.Flowable <Object>

Question

希望你们都在做威尔。我对此非常陌生，我不断地遇到不兼容类型的问题。

Flowable<Boolean> checkTriggerDaily() {

        List<Bson> fields = new ArrayList<Bson>();
        fields.add(exists("dueDate", true));
        Bson filter = and(fields);

        Flowable.fromPublisher(marketplaceMongoService.getCollection().find(filter)).map{ third ->
                    getTheReport(third.id).flatMap { size ->
                     TaskService.createTasks(size).toFlowable().flatMap({})
                    }
                }
    }

我在标题上一直有同样的错误。这个函数所做的是循环一个mongo集合，并调用getTheReport每一项。什么getTheReportReturns，我把它处理成createTasks函数。

getTheReport ->返回也许createTasks ->返回

Answer 1

因为

getTheReport(third.id).flatMap { size ->
    TaskService.createTasks(size).toFlowable().flatMap({})
}

结果是一个Flowalbe，您应该调用flatMap而不是map，以便将发出的内部函数解压到一个平面结果中：

Flowable<Boolean> checkTriggerDaily() {

    List<Bson> fields = new ArrayList<Bson>();
    fields.add(exists("dueDate", true));
    Bson filter = and (fields);

    Flowable.fromPublisher(marketplaceMongoService.getCollection().find(filter))
        .flatMap { third -> // flatMap instead of map
            getTheReport(third.id).flatMap { size ->
                TaskService.createTasks(size).toFlowable().flatMap({})
            }
        }
}