不理解 RxJava 中的 Observable.from 和 Observable.just

Question

我是 Rxjava 的新手。我正在关注一个视频教程，其中有一个调用 API 并使用平面图获取字符串结果的代码示例。下面是代码：

twitchAPI.getTopGamesObservable()
                .flatMap(new Func1<Twitch, Observable<Top>>() {
            @Override
            public Observable<Top> call(Twitch twitch) {
                Observable<Top> rtnTop =  Observable.from(twitch.getTop());
                Log.d("LogRx", "Size for FROM:"  + "\n");

                return rtnTop;
            }
        })
                .flatMap(new Func1<Top, Observable<String>>() {
            @Override
            public Observable<String> call(Top top) {
                Log.d("LogRx", "Size for JUST:"  + "\n");
                return Observable.just(top.getGame().getName());
            }
        })
                .subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()).subscribe(new Observer<String>() {
            @Override
            public void onCompleted() {     }

            @Override
            public void onError(Throwable e) {    }

            @Override
            public void onNext(String s) {  Log.d("LogRx", s);      }

        });

但我并没有真正理解这段代码如何工作的顺序。

混淆是因为 observable.from() 和 observable.just()。我知道 observable.from() 将为列表提供 N 个排放量，而 observable.just() 将提供 1 个排放量（一个列表）。

那么，这是否意味着第二个 flatMap 被调用了 N 次，因为第一个 flatMap 内的 Observable.from() 每次都会发出列表中的每个项目。对于第二个平面图，订阅者的 onNext() 也被调用 N 次（每次调用第二个平面图一次）？

Answer 1

那么，这是否意味着第二个 flatMap 被调用了 N 次，因为第一个 flatMap 中的 Observable.from() 每次都会发射列表中的每个项目。

第二张平面图（.flatMap(new Func1<Top, Observable<String>>() {）被称为twitch.getTop().size()次。

对于第二个 flatMap，订阅者的 onNext() 也被调用了 N 次

这是真的。根据Top，你会得到一个 observable，每个都有一个值。传递给onNext 的值的数量等于Tops 的数量。

这使得第二张平面地图有点臃肿。你也可以map 一个Top 到String。

---

无关：您可能想查找更新的教程。 RxJava1 差不多一年前就死了。

RxJava 1.x 现已正式生命周期结束 (EOL)。在版本 1.3.8 和 [2018 年 3 月 31 日] 之后，此项目将不再提供进一步的开发、错误修复、增强、javadoc 更改或维护。

鼓励用户migrate to 2.x。因此，该 wiki 将在未来几个月内更新以描述 2.x 的特性和属性。

来源：https://github.com/ReactiveX/RxJava/releases/tag/v1.3.8