rx-kotlin2

-1熱度

1回答

RxJava2：不是的onComplete與所謂flatMapIterable

這裏是代碼一小段： val subject = BehaviorSubject.createDefault(emptyList<Int>()) subject.onNext(Arrays.asList(1, 2, 3)) subject.flatMapIterable { list: List<Int> -> list } .subscribeBy(

kotlin rx-java2 rx-kotlin2 2017-10-05

---

0熱度

1回答

如何在RxJava2中默默跳過異常？

我有一個這樣的數據流： Observable .fromFuture( CompletableFuture.supplyAsync { // First remote call returns Future<List<Type>> listOf(1, 2, 3, 57005, 5) }, Schedulers.computation()

rx-java reactive-programming rx-java2 rx-kotlin rx-kotlin2 2017-08-24

---