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

  • 4
    いいね
  • 0
    コメント
この記事は最終更新日から1年以上が経過しています。
rx.Observable.create(subscriber -> {
    // バックグラウンドスレッドで何か
    // ...
    subscriber.onNext("something"); // 結果を返す。結果の型は任意
    subscriber.onCompleted();
})
        .subscribeOn(Schedulers.io()) // バックグランドスレッドを指定
        .observeOn(AndroidSchedulers.mainThread()) // メインスレッドを指定
        .subscribe(res -> {
            // 結果を受け取ってメインスレッドで何か
            // ...
        });

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