サクサク読めて、アプリ限定の機能も多数！
トップへ戻る
ChatGPT
qiita.com/jnikd
はじめに 短時間に大量にemitされるストリームに対して受け取った側で重い処理が実行される場合など、処理が追いつかずにあふれてしまうことがあります。そんな時にbackpressureを使います。 backpressureとは、ストリームの流れる量をコントロールする仕組みです。 RxJava2.xではObservableとFlowableが分離され、Observable = backpressureなし、Flowable = backpressureありとなっています。 この記事ではFlowableを使ってbackpressureを制御してみます。 サンプルはKotlinで実装しています。Kotlin経験がなくてもJavaでRxを扱ったことがあれば難しくないと思います サンプルアプリ 内容 シークバーを操作すると値の変化が大量にemitされる 受け取った側では実行に1000ミリ秒必要な処理
Deleted articles cannot be recovered. Draft of this article would be also deleted. Are you sure you want to delete this article?
このページを最初にブックマークしてみませんか？
『qiita.com』の新着エントリーを見る
j次のブックマーク
k前のブックマーク
lあとで読む
eコメント一覧を開く
oページを開く
