Я пытаюсь заархивировать 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 }
}
Что с этим не так?