【Unity】R3 CSharp 响应式编程 - 使用篇（二）

一、通用的事件监听用法

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, 并行执行");});}}}