Android上rxjava的默认调度程序

Question

我正在使用改型为我的异步网络调用返回rxjava Observable。

我发现自己重复以下调用：

someApiCall（）。subscribeOn（Schedulers.io（））。observeOn（AndroidSchedulers.mainThread（））

似乎我总是在IO线程上订阅，在Android主线程上观察。这似乎是我找到的所有资源都提倡的最佳实践。也许除了长时间运行的计算之外，我不太明白我们什么时候会想要偏离这种模式。

有没有办法通过默认subscribeOn和observeOn线程来删除这个样板文件？

这是rxjava插件的用例吗？（我找不到很多使用它们的示例。）

我可以通过修改执行器来设置网络边界上的默认线程吗？

Answer 1

是的，可以删除两个调用。

这是改造适配器类，它自动调度订阅和观察以消除每次调用中对样板调用的需要：

public class RxThreadingCallAdapterFactory extends CallAdapter.Factory {
    private final RxJava2CallAdapterFactory original;

    private RxThreadingCallAdapterFactory() {
        // Always call on background thread
        original = RxJava2CallAdapterFactory.createWithScheduler(Schedulers.io());
    }

    public static CallAdapter.Factory create() {
        return new RxThreadingCallAdapterFactory();
    }

    @Override
    public CallAdapter<?> get(Type returnType, Annotation[] annotations, Retrofit retrofit) {
        return new RxCallAdapterWrapper(original.get(returnType, annotations, retrofit));
    }

    private static class RxCallAdapterWrapper implements CallAdapter<Observable<?>> {
        private final CallAdapter<?> wrapped;

        public RxCallAdapterWrapper(CallAdapter<?> wrapped) {
            this.wrapped = wrapped;
        }

        @Override
        public Type responseType() {
            return wrapped.responseType();
        }

        @Override
        public <R> Observable<?> adapt(Call<R> call) {
            Observable observable = (Observable) wrapped.adapt(call);

            // Always handle result on main thread
            return observable.observeOn(AndroidSchedulers.mainThread());
        }
    }
}

然后在配置改装时使用此适配器：

Retrofit.Builder()
    .baseUrl(...)
    .addCallAdapterFactory(RxThreadingCallAdapterFactory.create())

我写了这篇博文，详细介绍了这里到底发生了什么。

这将删除这两个调用，我将其视为样板。我认为Jake将后台调用链接在一起的场景实际上并不适用，因为在这种情况下，我将对同步调用进行改造，而根本不使用调度器。

Answer 2

Retrofit Version 2.0.0-beta2 (2015-09-28)的更改日志显示在后台运行时需要订阅（）。

修复：请求的可观察和基于单一的执行现在表现为同步（因此需要在后台运行SubbeOn（））。

Answer 3

对于可观察的响应，Reformation当前将subscribeOn设置为RestAdapter（提供或默认）的HTTP执行器。这样做是为了将RxJava支持填充到现有行为中。

2.0的计划是提供显式设置订阅和观测默认值的能力（无论是同时设置、仅设置一个或两者都不设置）。

例如，您不希望始终观察主线程的一个原因是，如果您需要将多个API调用链接在一起。