java - RxAndroid 简化一个常见的模式？

Question

我发现自己一遍又一遍地写:

Observable.create(new Observable.OnSubscribe</* some type */>() {
        @Override
        public void call(Subscriber<? super /* some type */> subscriber) {
            try {
                subscriber.onNext(/* do something */);
                subscriber.onCompleted();
            } catch (IOException e) {
                subscriber.onError(e);
            }
        }
    }).observeOn(AndroidSchedulers.mainThread())
            .subscribeOn(Schedulers.newThread());

用于网络操作。

有什么办法可以减少重复吗？

Answer 1

第一个create可以替换为fromCallable。

Observable.fromCallable(() -> calculationReturnsAValue());

调度器的应用可以通过创建一个Transformer来实现:

Transformer schedulers = o -> 
    o.subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());

并用它作曲:

source.compose(schedulers);