UniRx 知らないと人権が無い気がしてきたので勉強した。

public event TimerEventHandler OnTimeChanged;
　　　　↓
private Subject<int> OnTimeChanged = new Subject<int>();

timeCounter.OnTimeChanged += time => {  };
　　　　↓
timeCounter.OnTimeChanged.Subscribe(time => {  });

OnTimeChanged(time);
　　　　↓
OnTimeChanged.OnNext(time);

//OnNextのみ
subject.Subscribe(msg => Debug.Log("Subscribe1:" + msg));

//OnNext & OnError
subject.Subscribe(
    msg => Debug.Log("Subscribe1:" + msg),
    error => Debug.LogError("Error" + error));

//OnNext & OnCompleted
subject.Subscribe(
    msg => Debug.Log("Subscribe1:" + msg),
    () => Debug.Log("Completed"));

//OnNext & OnError & OnCompleted
subject.Subscribe(
    msg => Debug.Log("Subscribe1:" + msg),
    error => Debug.LogError("Error" + error),
    () => Debug.Log("Completed"));

subject.
  .Where(x => x == "Enemy") //←フィルタリングオペレータ
  .Subscribe(x => Debug.Log(string.Format("プレイヤが{0}に衝突しました", x)));

var subject = new Subject<Unit>();
subject.Subscribe(x => Debug.Log(x));
subject.OnNext(Unit.Default);

var subject = new Subject<int>();
var disposable = subject.Subscribe(x => Debug.Log(x), () => Debug.Log("OnCompleted"));
disposable.Dispose();

    _timeCounter.OnTimeChanged
        .Where(x => x == 0) //タイマが0になった時のみ実行
        .Subscribe(_ =>
        {
            //タイマが0になったら初期座標に戻る
            transform.position = Vector3.zero;
        }).AddTo(gameObject); //指定のgameObjectが破棄されたらDisposeする

1. Subject<T> ： 上記で説明
2. BehaviorSubject<T> ： 最後に発行された物をキャッシュして、１つ前の値を発行する。
3. ReplaySubject<T> ： 過去全ての値を発行する。
4. AsyncSubject<T> ： OnCompletedが実行されたタイミングで、最後のOnNextのみ発行
5. ReactiveProperty<T> ： 変数１に対してSubjectを実装する。
6. ReactiveCollection<T> ： 配列に対してSubjectを付けたもの。
7. ReactiveDictionary<T1,T2> ： 連想配列に対してSubjectを付けたもの。
8. ObservableWWW ： 指定URL実行して、Subscribe できる。
9. Observable.NextFrame ： 次フレームで Subscribe できる。
10. Observable.EveryUpdate  ： よくわからない
11. ObserveEveryValueChanged ： 指定の変数が変更されたら Subscribe される。

        this.UpdateAsObservable()
            .Subscribe(
                _ => Debug.Log("Update!"), //OnNext
                () => Debug.Log("OnCompleted") //OnCompleted
            );

        // OnDestoryを受けてログに出す
        this.OnDestroyAsObservable()
            .Subscribe(_ => Debug.Log("Destroy!"));

public class ConvertFromCoroutine : MonoBehaviour
{
    void Start()
    {
        Observable.FromCoroutine(NantokaCoroutine, publishEveryYield: false)
            .Subscribe(
                _ => Debug.Log("OnNext"),
                () => Debug.Log("OnCompleted")
            ).AddTo(gameObject);
    }

    IEnumerator NantokaCoroutine()
    {
        Debug.Log("Coroutine started.");

        //なんか処理して待ち受ける的な
        yield return new WaitForSeconds(3);

        Debug.Log("Coroutine finished.");
    }
}

    Observable.WhenAll(
        Observable.FromCoroutine<string>(o => CoroutineA(o)),
        Observable.FromCoroutine<string>(o => CoroutineB(o))
    ).Subscribe(xs =>
    {
        foreach (var x in xs)
        {
            Debug.Log("result:" + x);
        }
    });

        Scheduler.ThreadPool.Schedule(() => Debug.Log("別スレッドで実行"));
        Scheduler.Immediate.Schedule(() => Debug.Log("すぐに実行"));
        Scheduler.MainThreadEndOfFrame.Schedule(() => Debug.Log("フレーム終了後に実行"));