RxJava/RxAndroid でバックグランドで何かして結果を受け取るコード例

  • 4
    Like
  • 0
    Comment
More than 1 year has passed since last update.
rx.Observable.create(subscriber -> {
    // バックグラウンドスレッドで何か
    // ...
    subscriber.onNext("something"); // 結果を返す。結果の型は任意
    subscriber.onCompleted();
})
        .subscribeOn(Schedulers.io()) // バックグランドスレッドを指定
        .observeOn(AndroidSchedulers.mainThread()) // メインスレッドを指定
        .subscribe(res -> {
            // 結果を受け取ってメインスレッドで何か
            // ...
        });

Java 8 と Retrolambda を利用しています。