facebook twitter hatena line email

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

提供: 初心者エンジニアの簡易メモ
移動: 案内検索
(Observable.Createを使う)
行1: 行1:
 +
ファクトリメソッド
 +
 
==Observable.Createを使う==
 
==Observable.Createを使う==
 
<pre>
 
<pre>
行25: 行27:
 
参考:https://qiita.com/toRisouP/items/86fea641982e6e16dac6
 
参考:https://qiita.com/toRisouP/items/86fea641982e6e16dac6
  
 +
参考:https://www.hanachiru-blog.com/entry/2021/06/07/135651
 
==時間後処理==
 
==時間後処理==
 
<pre>
 
<pre>

2021年10月14日 (木) 21:36時点における版

ファクトリメソッド

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