reactive

Rxjava ConnectableFlowable(Hotストリーム)のオペレータ

以下のバージョンで検証しました。 pom.xml <dependency> <groupId>io.reactivex.rxjava2</groupId> <artifactId>rxjava</artifactId> <version>2.1.14</version> </dependency> ConnectableFlowable ConnectableFlowableはHotなストリームで、複数のSubscriberに同じストリームを購読させるときに利用するクラス。 参考 ConnectableFlowable Javadoc p…

Rxjava onBackpressureBufferはいつ溢れるか?

前提知識 RxJavaにはバックプレッシャと呼ばれる、流量制御の仕組みがある。 参考 詳解RxJava2:Backpressureで流速制御 onBackpressureBuffer PublisherがSubscriberの消費スピードよりも早くデータを作った場合、バッファに生成されたデータを溜めておきた…

RXJava 無限ストリームでdistinct使ったらどうなる?

検証バージョン Java 1.8.0_25 RxJava 2.1.14 distinct distinct はフィルタ系操作の一つで、重複要素を取り除くためのメソッドです。 重複要素を取り除くためにはどこかに比較対象が存在しないといけないわけで、じゃあ無限ストリームとかどうやって対応す…

Spring WebFlux の概要を理解する

Spring WebFluxに関する、いまの理解を整理する。 Spring WebFlux 以前の問題点 Javaスレッドでコンテキストスイッチ? Spring WebFluxで課題をどう解決するか? Spring MVC と Spring WebFlux を比較する 検証環境 シナリオ 実装の違い Spring MVC Spring W…