あるBehaviorProcessor値を含む があるとしますv。
ここで、いくつかのデータを非同期的に要求したい場合は、v次のようにします。
val res = v.flatMapSingle { asyncRequest(it) }
次に、このブロック (マッパー) のすべての呼び出しをログに記録しましょう。
val res = v.flatMapSingle {
println("mapper")
asyncRequest(it)
}
複数回出力されますmapper。つまり、複数回呼び出されていることを意味しasyncRequestます。他の依存ストリームが変更されるたびに表示さsubscribeれます
複数のマッパー呼び出しを回避しようとしています (したがって、複数のasyncRequest呼び出しを回避します)。
標準の rxjava2 ユーティリティでこれを行う方法はありますか?