无法在rxjava 2中解析方法Observable.from

Question

在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);
                }
            })

Answer 1

您可以使用 Observable.fromIterable(source)

来自文档:

一些运算符重载已经使用后缀重命名,例如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);
            }
        })

Answer 2

您无需使用,.just()因为您可以Observable通过fromIterable()运营商直接从列表中创建.

    Observable.fromIterable(ints)

Answer 3

我想这有点晚了，但我只是想让人们知道，RxJava 文档中与from运算符相关的 API 更改：

from消歧义为fromArray, fromIterable,fromFuture