2017-08-11 1 views
0

私の質問は、各バッファの先頭で、バッファがいつ閉じるかを決定するobservableを返す関数を呼び出しているrxjavaバッファ(bufferClosingSelector)に関するものです。私の質問は、バッファが閉じたときに観測可能なものが自動的に終了するか、それとも自分自身を保証する必要があるということですか?バッファ(bufferClosingSelector)が自動的に終了している間にobservableが作成されます

答えて

0

bufferClosingSelectorは、上流の観測可能物が放出されている間、すなわちアイテムがbufferに入っている限り放出します。その上流の観測が完了すると、bufferClosingSelectorも同様に完了し、発光を停止します。あなたはそれを掃除するために何もする必要はありません。

+0

しかし、上流の観測値が決して終了しない場合や、長い時間が経過した場合、無限の数のアクティブな観測値を作成しないよう注意する必要があります。私が何かが欠けていない限り、これは私の質問に答える。ありがとう。 –

+0

@DavePosner、 'bufferClosingSelector'関数は1回だけ呼び出されるので、1つのオブザーバブルが作成されます。それは、上流の観測可能な観測が終了したときに起こる、観測が取り消されるまで発生します。 –

0

これは私のドキュメントの誤読に基づく愚かな質問でした。私がここで参照しているバッファ演算子のバージョンでは、bufferClosingSelector が完了したときにバッファが閉じます(イベントを発行しないときは)。ごめんなさい。

関連する問題