facebook twitter hatena line email

「Unity/UniRx/Observable」の版間の差分

提供: 初心者エンジニアの簡易メモ
移動: 案内検索
(時間後処理)
(同じ利用者による、間の6版が非表示)
行1: 行1:
 
==Observableとは==
 
==Observableとは==
Observableのファクトリメソッドは、Create以外にもたくさんある。https://qiita.com/toRisouP/items/3cf1c9be3c37e7609a2f
+
Observableのファクトリメソッドは、Create以外にもたくさんある。
  
 +
オペレーター一覧
 +
https://qiita.com/toRisouP/items/3cf1c9be3c37e7609a2f
 +
 +
一つのObserverを複数のViewで使える。詳しくは以下。
 +
 +
[[Unity/UniRx/複数イベント]] [ショートカット]
  
 
==Observable.Createを使う==
 
==Observable.Createを使う==
行35: 行41:
 
Observable.Timer(System.TimeSpan.FromSeconds(1))
 
Observable.Timer(System.TimeSpan.FromSeconds(1))
 
     .Subscribe(_ => Debug.Log("1秒後に実行"));
 
     .Subscribe(_ => Debug.Log("1秒後に実行"));
 +
 +
Observable.Timer(System.TimeSpan.FromSeconds(1))
 +
    .Subscribe(_ => { Debug.Log("1秒後に実行"); });
 
</pre>
 
</pre>
 
参考:https://qiita.com/toRisouP/items/86fea641982e6e16dac6
 
参考:https://qiita.com/toRisouP/items/86fea641982e6e16dac6
==一定時間処理==
+
===続けて一定時間処理===
 
<pre>
 
<pre>
 
// 1秒後から2秒間隔
 
// 1秒後から2秒間隔
行45: 行54:
 
</pre>
 
</pre>
 
参考:https://qiita.com/toRisouP/items/86fea641982e6e16dac6
 
参考:https://qiita.com/toRisouP/items/86fea641982e6e16dac6
 +
 +
==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

2022年4月12日 (火) 23:48時点における版

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秒後に実行"));

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です


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