为什么在RxJava中的每个可观察方法中都使用subscribeOn

Question

getUserWalable方法发出一些用户，我需要知道为什么他把. subbeOn（Schedulers.io（）），而他已经在main funcion上调用它，我提供了这两种方法的截取，我知道，subbeOn将使进程发生在后台线程上，但当他调用它两次时，这会有什么不同，我不知道，因为我理解只是在getUsersWalable中调用一次就足够了

private Observable<User> getUsersObservable() {
    String[] maleUsers = new String[]{"Mark", "John", "Trump", "Obama"};

    final List<User> users = new ArrayList<>();

    for (String name : maleUsers) {
        User user = new User();
        user.setName(name);
        user.setGender("male");

        users.add(user);
    }

    return Observable
            .create(new ObservableOnSubscribe<User>() {
                @Override
                public void subscribe(ObservableEmitter<User> emitter) throws Exception {
                    for (User user : users) {
                        if (!emitter.isDisposed()) {
                            emitter.onNext(user);
                        }
                    }

                    if (!emitter.isDisposed()) {
                        emitter.onComplete();
                    }
                }
            }).subscribeOn(Schedulers.io());
}

@Override
protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.activity_map_operator);

    getUsersObservable()
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .map(new Function<User, User>() {
                @Override
                public User apply(User user) throws Exception {
                    // modifying user object by adding email address
                    // turning user name to uppercase
                    user.setEmail(String.format("[e-mail]", user.getName()));
                    user.setName(user.getName().toUpperCase());
                    return user;
                }
            })
            .subscribe(new Observer<User>() {
                @Override
                public void onSubscribe(Disposable d) {
                    disposable = d;
                }

                @Override
                public void onNext(User user) {
                    Log.e(TAG, "onNext: " + user.getName() + ", " + user.getGender() + ", " + user.getAddress().getAddress());
                }

                @Override
                public void onError(Throwable e) {
                    Log.e(TAG, "onError: " + e.getMessage());
                }

                @Override
                public void onComplete() {
                    Log.e(TAG, "All users emitted!");
                }
            });
}

Answer 1

这通常有两个原因：

• 您可以在调用方法的地方看到，可观察对象订阅在哪个调度器上（如果这是在外部不知道的方法中完成的）
• 您可以使用相同的方法，并在应用程序不同位置的不同调度器上订阅它

但是如果您确定，它总是同一个调度器，那么您也可以将subscribeOn（）移动到方法本身中。

编辑

我没有看到，那是。subscribeOn（Schedulers.io（））已在方法中调用。调用方法时，在方法内部和外部调用它是没有意义的。对我来说，这似乎是一个错误。如上所述，通常。subscribeOn（）在方法外部调用，但也可以在内部调用。两者兼而有之毫无意义。