RxJavaリアクティブプログラミング (CodeZine BOOKS) 新品価格 |
RxJavaでFlowable.createを使う
の続編
次はflatmapを使ってみた
・コード全部記載
Flowable.just("A", "B", "C")
.flatMap(new Function>() {
@Override
public Publisherapply(@NonNull String s) throws Exception {
return Flowable.just(s).delay(1000L, TimeUnit.MILLISECONDS);
}
})
.subscribe(new Consumer() {
@Override
public void accept(String o) throws Exception {
System.out.println("flatmap :"+o);
}
});
・コード with ラムダ
Flowable.just("A", "B", "C")
.flatMap(data -> Flowable.just(data).delay(1000L, TimeUnit.MILLISECONDS))
.subscribe(data -> System.out.println("flatmap :"+data));
久々にコード書いたので全然うまく書けなかった
もう少しだけ続くよ