一、通用的事件監聽用法
using System;using R3;using UnityEngine;namespace Aladdin.Standard.Observable.Common{public class CommonObservable : MonoBehaviour{// 默認會調用1次public SerializableReactiveProperty<int> serializableReactiveProperty;// 默認會調用1次public readonly ReactiveProperty<int> reactiveProperty = new ReactiveProperty<int>();private void Start(){this.serializableReactiveProperty.Subscribe((value) => { Debug.LogError($"Unity Serializable Value Change: {value}"); });this.reactiveProperty.Subscribe((value) => { Debug.LogError($"Reactive Property Value Change: {value}"); });// 執行到規定幀數后回調,下文是到 999 幀后回調。R3.Observable.TimerFrame(999).Subscribe(value =>{Debug.LogError($"{Time.frameCount}");});// 500ms 回調內容R3.Observable.Timer(TimeSpan.FromMilliseconds(500)).Subscribe(_ => { Debug.LogError($" 500ms 回調一次"); });// 立即調用 2 次,每次的值是 1R3.Observable.Repeat(1, 2).Subscribe(value => { Debug.LogError($"立即調用 2 次, 每次的值是:{value}"); });// 間隔 1000ms 調用, 可以嘗試使用 ReactiveProperty 額外記錄一個值,目前還不知道怎樣監聽調用次數, 可使用 Concat 嘗試R3.Observable.Interval(TimeSpan.FromMilliseconds(1000)).Subscribe(_ =>{this.reactiveProperty.Value += 1;});// 雙擊,如果第二次按鍵在第一次按鍵的 250ms 的間隔內,那就是雙擊Observable<Unit> clickStream = R3.Observable.EveryUpdate().Where(_ => Input.GetMouseButtonDown(0));clickStream.Chunk(clickStream.Debounce(TimeSpan.FromMilliseconds(250))).Where(xs => xs.Length >= 2).Subscribe(_ => Debug.Log("Mouse double click detected!"));// 連接兩個 Observablevar concat1 = R3.Observable.Timer(TimeSpan.FromMilliseconds(1000));R3.Observable.Concat(concat1, concat1).Subscribe(_ =>{Debug.LogError("Concat: 連接兩個 Observable, 按順序執行");});// 連接兩個 Observablevar merge1 = R3.Observable.Timer(TimeSpan.FromMilliseconds(1000));R3.Observable.Merge(merge1, merge1).Subscribe(_ =>{Debug.LogError("Merge: 合并兩個 Observable, 并行執行");});}}}