【UniRx】Observable.FromCoroutineで再度購読する方法について

Question

UniRxのFromCoroutineを使用し、コルーチン終了後にSubscribeしている処理を実行するような処理を行いたく、下記のように
コルーチンの実行を行っているのですが、これは一度実行されるとDisposeされてしまい、再度使いまわすようなことができなくなってしまいます。
用途としては複数回使用したいため、コルーチン実行後もDisposeしてほしくないのですが、させない方法などありますでしょうか。
※通常のUnityのコルーチンでは、コルーチンの終了検知にひと手間加えなくてはならず、できればUniRxの機能で実現したい所です。

// hogeCoroutineの実行終了後、hogeMethodが実行される
Observable.FromCoroutine(hogeCoroutine)
            .Subscribe(_ => hogeMethod());

Answer 1

Observable/UniRxで統一したいのであれば、Repeat系オペレータを利用すれば出来るんじゃないでしょうか。

Repeatとは、書籍「UniRx/UniTask 完全理解」の説明を引用させて頂くと

RepeatはOnCompletedメッセージを受け取った時にSubscribe()をやりなおします。つまり

直前までのObsevableを新しく生成し直して、それをSubscribe()するのと同じ動作を行います。

とあります。

ただし、注意点として（こちらも同書籍から引用）

Repeatを使用する場合の注意点
Repeatを用いるとOnCompleted メッセージで Observable を停止できなくなる

とありますように、Repeat()は無限ループを発生させる可能性があるので、RepeatSafe()やRepeatUntilDestory()を利用したほうがいいようです。

参考：【Unity】【UniRx】Repeat系のオペレータまとめ

---

あるいは単にコルーチンの扱いが面倒なら UniTask によってコルーチンを await 出来るので、そちらを検討してみてはどうでしょう。

UniTask機能紹介 #コルーチンのawait

async UniTask DoHogeAsync()
{
    await hogeCoroutine();
    hogeMethod();
}

Comments

[gimn]

tor4kichi様
ご回答いただきありがとうございました。
表記の問題につきまして、私の実装に誤りがあり想定の動作となっていなかったことが判明いたしました。申し訳ございません。
Observable.FromCoroutineは繰り返し呼び出しても再度実行してくれるようでした。
ただ、ご提案いただいた方法で同様の実装が行えるということで大変勉強になりました。
今後の実装にてご参考にさせていただきたいと思います。