rxjava 1 中的 Observable 类中有一个 from 方法,但在 rxjava 2 中找不到。如何在以下代码中替换 rxjava 2 中的 from 方法:
List<Integer> ints = new ArrayList<>();
for (int i=1; i<10; i++) {
ints.add(new Integer(i));
}
Observable.just(ints)
.flatMap(new Function<List<Integer>, Observable<Integer>>() {
@Override
public Observable<Integer> apply(List<Integer> ints) {
return Observable.from(ints);
}
})
您可以使用Observable.fromIterable(source)
From 文档 https://github.com/ReactiveX/RxJava/wiki/What's-different-in-2.0:
一些运算符重载已用后缀重命名,例如
fromArray、fromIterable 等。这样做的原因是,当
库是用Java 8编译的,javac通常无法消除歧义
功能接口类型之间。
List<Integer> ints = new ArrayList<>();
for (int i=1; i<10; i++) {
ints.add(new Integer(i));
}
Observable.just(ints)
.flatMap(new Function<List<Integer>, Observable<Integer>>() {
@Override
public Observable<Integer> apply(List<Integer> ints) {
return Observable.fromIterable(ints);
}
})
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)