2018-06-23から1日間の記事一覧

Rxjava subscribeOnとobserveOnで実行スレッドを指定する

課題 Rxjavaで以下のようなコードを実行すると、 @Test public void 実行スレッドを切り替える() throws InterruptedException { Flowable.just("hello") .doOnNext(val -> logger.info("emit")) .map(o -> o) .doOnNext(val -> logger.info("map")) .subscr…