Unity/UniRx/Observable
Observableとは
Observableのファクトリメソッドは、Create以外にもたくさんある。
オペレーター一覧 https://qiita.com/toRisouP/items/3cf1c9be3c37e7609a2f
一つのObserverを複数のViewで使える。詳しくは以下。
Unity/UniRx/複数イベント [ｼｮｰﾄｶｯﾄ]
Observable.Createを使う
Observable.Create<int>(observer =>
{
for (var i = 1; i <= 3; i++)
{
observer.OnNext(i);
}
Debug.Log("Finished");
observer.OnCompleted();
return Disposable.Create(() =>
{
Debug.Log("Dispose");
});
}).Subscribe(x => Debug.Log(x));
ログ
1 2 3 Finished Dispose
参考：https://qiita.com/toRisouP/items/86fea641982e6e16dac6
参考：https://www.hanachiru-blog.com/entry/2021/06/07/135651
時間後処理
// 1秒後に実行
Observable.Timer(System.TimeSpan.FromSeconds(1))
.Subscribe(_ => Debug.Log("1秒後に実行"));
参考：https://qiita.com/toRisouP/items/86fea641982e6e16dac6
一定時間処理
// 1秒後から2秒間隔
Observable.Timer(System.TimeSpan.FromSeconds(1), System.TimeSpan.FromSeconds(2))
.Subscribe(_ => Debug.Log("2秒間隔に実行"))
.AddTo(gameObject);
参考：https://qiita.com/toRisouP/items/86fea641982e6e16dac6
Defarの使い方
IObservable<string> deferObservable;
void MainObservableDefer()
{
deferObservable = Observable.Return(DateTime.Now.ToString() + "です"); // ここは先に実行される
Invoke("ObservableDefer", 10);
}
void ObservableDefer()
{
Observable.Defer(() =>
deferObservable
).Subscribe(msg => {
Debug.Log(msg); // ここは、Subscribe時に実行される
});
}
ログ
[19:33:25] 11/12/2021 7:33:14 PMです