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
Deferの使い方
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です