RxJavaを使い始めたので、書いてみました。 始まりのコード RxJavaを使えば、Threadの作成、管理をしなくてよく、お任せできるということなので便利そうなのですが、 勉強途中いったいどのThreadで何が起こっているのか分からなくなったので、書いて実験です。 まずは、 itemを3発 発射するObserableと,それに反応して処理するObserverをsubscribeします。 rxjava2でやります。 import io.reactivex.Observable; public class RxJava2 { public static void main(String[] args){ Observable.just("a","bb","ccc") .subscribe( (item)-> System.out.println("item :"+item)); } }