「Unity/UniRx/Observable」の版間の差分
提供: 初心者エンジニアの簡易メモ
(ページの作成:「==Observable.Createを使う== <pre> Observable.Create<int>(observer => { for (var i = 1; i <= 3; i++) { observer.OnNext(i); } Debug.Log("Finished...」) |
(→遅延処理) |
||
(同じ利用者による、間の13版が非表示) | |||
行1: | 行1: | ||
+ | ==Observableとは== | ||
+ | Observableのファクトリメソッドは、Create以外にもたくさんある。 | ||
+ | |||
+ | オペレーター一覧 | ||
+ | https://qiita.com/toRisouP/items/3cf1c9be3c37e7609a2f | ||
+ | |||
+ | 一つのObserverを複数のViewで使える。詳しくは以下。 | ||
+ | |||
+ | [[Unity/UniRx/複数イベント]] [ショートカット] | ||
+ | |||
==Observable.Createを使う== | ==Observable.Createを使う== | ||
<pre> | <pre> | ||
行14: | 行24: | ||
}); | }); | ||
}).Subscribe(x => Debug.Log(x)); | }).Subscribe(x => Debug.Log(x)); | ||
+ | </pre> | ||
+ | ログ | ||
+ | <pre> | ||
+ | 1 | ||
+ | 2 | ||
+ | 3 | ||
+ | Finished | ||
+ | Dispose | ||
</pre> | </pre> | ||
参考:https://qiita.com/toRisouP/items/86fea641982e6e16dac6 | 参考:https://qiita.com/toRisouP/items/86fea641982e6e16dac6 | ||
+ | |||
+ | 参考:https://www.hanachiru-blog.com/entry/2021/06/07/135651 | ||
+ | ==Deferの使い方== | ||
+ | <pre> | ||
+ | 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時に実行される | ||
+ | }); | ||
+ | } | ||
+ | </pre> | ||
+ | ログ | ||
+ | [19:33:25] 11/12/2021 7:33:14 PMです | ||
+ | |||
+ | |||
+ | https://soramamenatan.hatenablog.com/entry/2021/02/27/141540#%E5%80%A4%E3%82%921%E3%81%A4%E3%81%A0%E3%81%91%E7%99%BA%E8%A1%8C | ||
+ | |||
+ | ==Observable.Timer== | ||
+ | [[Unity/UniRx/遅延処理]] [ショートカット] |
2022年12月3日 (土) 00:18時点における最新版
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
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です
Observable.Timer
Unity/UniRx/遅延処理 [ショートカット]