2016-12-03 15 views

答えて

28

:RxJavaの0.xであるに背圧を導入約

小さな後悔ではなく別個のベース反応性クラスを有することが、観測 自体を改造した ことです。バックプレッシャーの主な問題は、UIイベントなどの多くの ホットソースが合理的にバックプレッシャーを受けることができず、予期せぬMissingBackpressureException( は予期しない)を引き起こすということです。

我々は io.reactivex.Observable非バックプレッシャと新しい io.reactivex.Flowableは背圧対応の基本反応クラスもを持つことにより、2.xでこの状況を改善しようとします。

使用Observableあなたは時間(< 1000)および/またはそこプロデューサーoverflooding消費者の危険ませんので、原因OOMにわたって比較的少数のアイテムを持っています。

Flowableを使用すると、アイテムが比較的多く、リソースの枯渇や混雑を避けるために、Producerの動作を慎重に制御する必要があります。


背圧 あなたは、消費者が放出されるが、消費されていないアイテムの存在につながる流れに追いつくことができないので、高速なアイテムを放出する観測可能があります。

オブザーバによって放出されるが、購読者によって消費されない消費されていないアイテムは、バックプレッシャー戦略が扱うものです。

Ref link

+2

私は彼らがまだ共通のインターフェースをサポートしなければならないと思います。あるいは、FlowableはObservableを拡張して、それらをマージするなどの方法で拡張するべきです –

関連する問題