Как заархивировать список <Flowable>, используя RxJava2 в Kotlin? - PullRequest
0 голосов
/ 11 июня 2018

Я пытаюсь заархивировать List<Flowable>, используя RxJava2, но он не скомпилируется.Фрагмент кода выглядит следующим образом:

private fun flowInts() {
    val flows = ArrayList<Flowable<Int>>()
    for (i in 0..10) {
        flows.add(getFlow(i))
    }

    Flowable.zip(flows, Function<Array<Int>, List<Int>> {array -> // I get compile error at Flowable.zip
        array .toList()
    })
}

private fun getFlow(i: Int): Flowable<Int> {
    return Flowable.fromCallable { return@fromCallable i }
}

Что с этим не так?

...