RxJava - BackpressureStrategy の種類

今回は Backpressure の挙動を指定するための列挙型、BackpressureStrategy について見ていきます

BackpressureStrategy とは

Flowable は場合によって生成スピードが Subscribe の処理速度以上に速い場合があります。そういった場合は、データは通知されるのを待つことになります。その待つデータに関する挙動を指定するのが BackpressureStrategy です。

BackpressureStrategy の種類一覧

	概要
BUFFER	消費者に通知されるまで、すべてのデータがバッファされる
DROP	消費者にデータが通知できるようになるまでに生成されたデータを破棄する
LATEST	生成された最新のデータ（１件）のみをバッファし、生成される度に最新のデータで上書きする
ERROR	通知待ちとなっているバッファデータが最大バッファサイズを超えた場合に MissingBackpressureException が発生し、エラー通知する
NONE	処理は行わず、onBackpressureBuffer（int capacity）　または　他のパラメータ化された onBackpressureXXX メソッドを使用する場合に使用可能

参考

RxJavaリアクティブプログラミング (CodeZine BOOKS)