UniRxを利用したタイマーを制作し好きなタイミングから何度でも呼べるようにしたい

Question

前提

UnityでタイマーをUniRxを利用し作成することで終了後の処理が簡単に書けるのではないかと思いましたが、思いのほかうまくいかないのでこちらに質問させて頂きました。

実現したいこと

• UniRxを利用したタイマーを制作
• 終了時に好きな動作を追加できるようにする
• 好きなタイミングで好きなだけ呼べる形にしたい

該当のソースコード

 public class TimeSet : MonoBehaviour
    {
        [SerializeField] public int reserveTime;


        public IConnectableObservable<int> _connectableObservable;

        public IObservable<int> ReserveCountTime => _connectableObservable.AsObservable();


        private void Awake()
        {
            _connectableObservable = CreateCountDownObservable(reserveTime).Publish();
        }

        private void Start()
        {
            _connectableObservable.Connect();
        }

        /// <summary>
        /// タイマー
        /// </summary>
        /// <param name="countTime">計測時間</param>
        /// <returns></returns>
        private static IObservable<int> CreateCountDownObservable(int countTime)
        {
            return Observable
                .Timer(TimeSpan.FromSeconds(0), TimeSpan.FromSeconds(1))
                .Select(x => (int)(countTime - x))
                .TakeWhile(x => x > 0);
   }

public class WaveManager : MonoBehaviour
    {
        [SerializeField] private MainView mainView;
        [SerializeField] private TimeSet timeSet;
       
        readonly ISubject<Unit> _onSomethingRequested = new Subject<Unit>();

        private void Awake()
        {// `Subscribe`初期化位置以外に書かない方がよいとのことなのでこちらにまとめました。
            _onSomethingRequested
                .SelectMany((IEnumerator)timeSet.ReserveCountTime.First(time => time <= 0)
                    .Subscribe(_ => mainView.WeaponBarHide()).AddTo(this));
        }

        public void ReserveCountTimeStart()
        {
            Debug.Log("CountStart");
            //タイマー始動
            timeSet._connectableObservable.Connect();
            //タイマー終了後の処理を追加
            _onSomethingRequested.OnNext(Unit.Default);
        }
    }

###エラー文
InvalidCastException: Specified cast is not valid.

InvalidOperationException: sequence is empty System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw () (at <695d1cc93cca45069c528c15c9fdd749>:0)

試したこと

timeSet._connectableObservable.Connect();
こちらからタイマーを始動させ

_onSomethingRequested.OnNext(Unit.Default);
こちらからタイマー終了後の処理を呼び出しています。

UniRxでカウントダウンタイマーを作る
こちらの記事を参考にタイマーを制作しました。

リアクティブスパゲティを避けるための2つの原則
こちらの記事を参考にタイマー終了後の処理をできるようにさせようと思いました。

補足情報（FW/ツールのバージョンなど）

Unity 2020.3.20f1

UniRx Ver 7.1.0

Answer 1

実現したい動作は「好きなタイミングでWaveManagerのReserveCountTimeStartを実行するとカウントダウンが始まり、TimeSetのreserveTimeで指定されたカウントが経過した後に何らかの処理...たとえばMainViewのWeaponBarHideを実行する」ということでいいでしょうかね?

ご参考になさった「【Unity】UniRxでカウントダウンタイマーを作る - Qiita」に...

ただし、このCreateCountDownObservableで作ったストリームはColdであるという点に注意する必要があります。
（Subscribeしたタイミングで始めてカウントダウンが開始される点、1つのタイマストリームを複数SubscribeするにはHot変換が必要である点）

との記述がありますが、今回のようにReserveCountTimeStartでカウントダウンを開始するのでしたらTimeSetのStartで勝手にカウントダウンを開始してしまうのはまずい...つまり記事とは逆にColdでないと不便なような気がします。

もっとシンプルな作りでいいんじゃないでしょうか。たとえば下記のような形ではどうでしょう。

using System;
using UniRx;
using UnityEngine;

public class TimeSet : MonoBehaviour
{
    [SerializeField] public int reserveTime;
    
    public IObservable<int> ReserveCountTime => CreateCountDownObservable(reserveTime);
    
    /// <summary>
    /// タイマー
    /// </summary>
    /// <param name="countTime">計測時間</param>
    /// <returns></returns>
    private static IObservable<int> CreateCountDownObservable(int countTime)
    {
        return Observable
            .Timer(TimeSpan.FromSeconds(0), TimeSpan.FromSeconds(1))
            .Select(x => (int)(countTime - x))
            .TakeWhile(x => x > 0);
    }
}

using UniRx;
using UnityEngine;

public class WaveManager : MonoBehaviour
{
    [SerializeField] private MainView mainView;
    [SerializeField] private TimeSet timeSet;

    public void ReserveCountTimeStart()
    {
        Debug.Log("CountStart");

        timeSet.ReserveCountTime
            .Do(x => Debug.Log($"Timer count: {x}")) // 参考情報としてコンソールにカウントを表示
            .DoOnCompleted(() => mainView.WeaponBarHide()) // ストリーム完了時に目的の処理を実行するよう予約
            .Subscribe().AddTo(this); // 購読を開始（タイマーを始動）
    }
}

あるいはSubscribeは初期化時のみに行うというルールに準拠するとなると、WaveManagerは下記のようにすることになるでしょうかね?

using UniRx;
using UnityEngine;

public class WaveManager : MonoBehaviour
{
    [SerializeField] private MainView mainView;
    [SerializeField] private TimeSet timeSet;

    private readonly ISubject<Unit> _onWeaponBarHideRequested = new Subject<Unit>();

    private void Awake()
    {
        _onWeaponBarHideRequested.SelectMany(
            timeSet.ReserveCountTime
                .Do(x => Debug.Log($"Timer count: {x}"))
                .DoOnCompleted(() => mainView.WeaponBarHide()))
            .Subscribe().AddTo(this);
    }

    public void ReserveCountTimeStart()
    {
        Debug.Log("CountStart");
        _onWeaponBarHideRequested.OnNext(Unit.Default);
    }
}