美文网首页Android进阶
RxAndroid 和 RxKotlin

RxAndroid 和 RxKotlin

作者: 三流之路 | 来源:发表于2018-06-09 23:34 被阅读0次

ReactiveX 系列文章目录


RxAndroid

implementation 'io.reactivex.rxjava2:rxandroid:2.0.2'
RxAndroid.png

RxAndroid 是在 RxJava 上的扩展,用法和 RxJava 一样。结构比较简单,主要用在 Android 上的线程切换。

Observable.just(1,2)
    .subscribeOn(Schedulers.io())
    // 切换到 Android 的主线程
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(observerInt)

看源码

public static Scheduler mainThread() {
    return RxAndroidPlugins.onMainThreadScheduler(MAIN_THREAD);
}

private static final Scheduler MAIN_THREAD = RxAndroidPlugins.initMainThreadScheduler(
    new Callable<Scheduler>() {
        @Override public Scheduler call() throws Exception {
            return MainHolder.DEFAULT;
        }
    });
    
private static final class MainHolder {
    static final Scheduler DEFAULT = new HandlerScheduler(new Handler(Looper.getMainLooper()));
}

通过 Looper.getMainLooper() 构建的 Handler 来切换。

看 HandlerScheduler 内部类 HandlerWorker 的 schedule 方法:

@Override
public Disposable schedule(Runnable run, long delay, TimeUnit unit) {
    ...

    run = RxJavaPlugins.onSchedule(run);

    ScheduledRunnable scheduled = new ScheduledRunnable(handler, run);

    Message message = Message.obtain(handler, scheduled);
    message.obj = this; // Used as token for batch disposal of this worker's runnables.

    handler.sendMessageDelayed(message, unit.toMillis(delay));

    // Re-check disposed state for removing in case we were racing a call to dispose().
    if (disposed) {
        handler.removeCallbacks(scheduled);
        return Disposables.disposed();
    }

    return scheduled;
}

内部原理就是 Android 的 Handler 这一套机制。

除了切换到主线程还可以根据某个线程上的 Looper 切换到指定线程上。

Looper backgroundLooper = // ...
Observable.just("one", "two", "three", "four", "five")
        .observeOn(AndroidSchedulers.from(backgroundLooper))
        .subscribe(/* an Observer */)

就是根据传入的 Looper 构建一个 Handler。

public static Scheduler from(Looper looper) {
    if (looper == null) throw new NullPointerException("looper == null");
    return new HandlerScheduler(new Handler(looper));
}

RxKotlin

implementation 'io.reactivex.rxjava2:rxkotlin:2.2.0'

用 Kotlin 语言写 RxJava 的功能就行,但 Kotlin 本身有些语言特性(比如扩展),使用 RxKotlin 后语法可以更简洁。类似 Google 的 ktx 框架,没什么新功能,只是对一些方法的封装使得使用起来更方便。

RxJava 是调用 Observable 的方法,比如:

Observable.fromArray("a","b","c").subscribe(observerStr)

而使用 RxKotlin 就是这样

arrayOf("a", "b", "c").toObservable().subscribe(observerStr)

源码

fun <T : Any> Array<T>.toObservable(): Observable<T> = Observable.fromArray(*this)

在数组上定义的扩展方法 toObservable() 内部其实就是调用的 fromArray 方法。

其实扩展方法更符合人的思维,不像原来那种,乍看之下是别扭的。

全部的扩展方法见 https://github.com/ReactiveX/RxKotlin

相关文章

  • RxAndroid 和 RxKotlin

    ReactiveX 系列文章目录 RxAndroid RxAndroid 是在 RxJava 上的扩展,用法和 R...

  • RxJava(RxKotlin)、RxAndroid 简单使用

    RxJava(RxKotlin)、RxAndroid ps:文章中涉及到的代码均使用 Kotlin 实现,即需要导...

  • 第十五周 RxJava 和 RxAndroid

    话题:用过 RxJava 和 RxAndroid 吗?RxAndroid 切换线程是怎么实现的呢?关键字:RxJa...

  • RxJava笔记

    1、RxJava和RxAndroid的区别: RxAndroid是特别针对Android这个平台增加了更新UI...

  • 浅谈 RxAndroid + Retrofit + Databi

    浅谈 RxAndroid + Retrofit + Databinding 最近 RxAndroid 、MVP、M...

  • RxJava和RxAndroid

    RxJava介绍 首先要说明的一点,RxAndroid和RxJava是差不多的东西,只不过RxAndroid 针对...

  • 初识Rxjava

    星球话题:用过RxJava和RxAndroid吗?RxAndroid切换线程是怎么实现的呢? 去年知乎上参加了玉刚...

  • RxJava和RxAndroid

    前言 Rx是一个实现异步操作的库,它使的代码更加简洁易读,去年开始在公司的项目中已经开始使用了,大大简化了开发流程...

  • 优美的异步 --- RxAndroid

    优美的异步 --- RxAndroid 这里和大家一起分享一下一个著名的Android异步库RxAndroid。它...

  • Rx家族 - 收藏集 - 掘金

    拆 JakeWharton 系列之 RxAndroid - 掘金准确来讲,RxAndroid 是隶属于 React...

网友评论

    本文标题:RxAndroid 和 RxKotlin

    本文链接:https://www.haomeiwen.com/subject/mrwxeftx.html