using System;
using UnityEngine;
using UnityEngine.UI;
using UniRx;

public class Sample : MonoBehaviour
{
    // ボタン 1
    [SerializeField]
    private Button _button1;
    // ボタン 2
    [SerializeField]
    private Button _button2;
    // ボタンの押下許可
    private BoolReactiveProperty _sharedCanExecuteSource = new BoolReactiveProperty(true);
    
    private void Start()
    {
        var command1 = new AsyncReactiveCommand(this._sharedCanExecuteSource);
        command1.BindToOnClick(this._button1, _ =>
        {
            return Observable.Timer(TimeSpan.FromSeconds(1))
                .ForEachAsync(__ => Debug.Log($"button1"));
        });
        
        var command2 = new AsyncReactiveCommand(this._sharedCanExecuteSource);
        command2.BindToOnClick(this._button2, _ =>
        {
            return Observable.Timer(TimeSpan.FromSeconds(1))
                .ForEachAsync(__ => Debug.Log($"button2"));
        });
    }
}

省略して下記のように書くこともできる。

using System;
using UnityEngine;
using UnityEngine.UI;
using UniRx;

public class Sample : MonoBehaviour
{
    // ボタン 1
    [SerializeField]
    private Button _button1;
    // ボタン 2
    [SerializeField]
    private Button _button2;
    // ボタンの押下許可
    private BoolReactiveProperty _sharedCanExecuteSource = new BoolReactiveProperty(true);
    
    private void Start()
    {
        this._button1
            .BindToOnClick(this._sharedCanExecuteSource, _ => 
            {
                return Observable.Timer(TimeSpan.FromSeconds(1))
                    .ForEachAsync(__ => Debug.Log($"button1"));
            });
        this._button2
            .BindToOnClick(this._sharedCanExecuteSource, _ => 
            {
                return Observable.Timer(TimeSpan.FromSeconds(2))
                    .ForEachAsync(__ => Debug.Log($"button2"));
            });
    }
}

www.youtube.com

2021-06-06

【Unity】【UniRx】ReactiveDictionary で辞書を監視する

Unity UniRx

using UnityEngine;
using UniRx;

public class Sample : MonoBehaviour
{
    private ReactiveDictionary<int, string> _intDictionary = new ReactiveDictionary<int, string>();
    
    private void Start()
    {
        // 辞書を購読する
        this._intDictionary
            .ObserveAdd()
            .Subscribe(value =>
            {
                Debug.Log($"[Add]Key={value.Key},Value={value.Value}");
            });
        this._intDictionary
            .ObserveRemove()
            .Subscribe(value =>
            {
                Debug.Log($"[Remove]Key={value.Key},Value={value.Value}");
            });
        this._intDictionary
            .ObserveReplace()
            .Subscribe(value =>
            {
                Debug.Log($"[Replace]Key={value.Key},NewValue={value.NewValue},OldValue={value.OldValue}");
            });
        this._intDictionary
            .ObserveReset()
            .Subscribe(value =>
            {
                Debug.Log($"[Reset]");
            });
            

        // 値を変える
        this._intDictionary.Add(0, "1st");
        this._intDictionary.Add(1, "2nd");
        this._intDictionary.Add(2, "3rd");
        this._intDictionary.Remove(0);
        this._intDictionary.Clear();
    }
}