【ReactiveExtensions】「Repeat」とは何なのか? - Qiita

UniRxについての記事のまとめはこちら RxのRepeatは頻繁に使う割に挙動が読めず、初心者がハマってしまうオペレータだと思います。 そこでRepeatについて調べてまとめてみました。 Rxの「Repeat」とは？ 一言で言えばRepeatは「OnCompletedが来た時に再Subscribeしてくれるオペレータ」です。 （更に正確に言えば、OnCompletedが来た時に同じストリームを生成してConcatで後ろに繋げてくれるオペレータです） 稀に「流れてきたメッセージを再現して繰り返してくれるオペレータ」と勘違いされている方が居ますがそうではありません。 例えば以下のコードを御覧ください。 var random = new Random(); //乱数を1つ返すストリーム Observable.Create<int>(observer => { observer.OnNext(r

[mizoguche]

“RepeatはOnCompletedが来た時にSubscribeをやり直してくれるオペレータです。…「再Subscribeする＝オペレータを全て初期化する」と考えることができます。”