廊坊哪里有做网站建设的wordpress 页面是什么意思

廊坊哪里有做网站建设的,wordpress 页面是什么意思,做电子签章登录哪个网站,武进建设局网站首页一、Observable 概述1.1 什么是 ObservableObservable 是 UniRx 中的核心概念#xff0c;代表一个可观察的数据流。它可以发射多个值#xff08;异步或同步#xff09;#xff0c;订阅者可以监听这些值。1.2 Observable 的特点可观察#xff1a;数据源可以被订阅可组合代表一个可观察的数据流。它可以发射多个值异步或同步订阅者可以监听这些值。1.2 Observable 的特点可观察数据源可以被订阅可组合多个 Observable 可以组合成新的数据流可操作支持各种操作符进行数据转换可订阅允许一个或多个订阅者监听二、创建 Observable 的常用方法2.1 基础创建方法csharp// 1. 创建一个发射单个值的 Observable Observable.Return(Hello) .Subscribe(msg Debug.Log(msg)); // 2. 创建一个空的 Observable立即完成 Observable.Emptyint() .Subscribe( onNext: x Debug.Log(x), // 不会执行 onCompleted: () Debug.Log(Completed) // 立即执行 ); // 3. 创建一个永不结束的 Observable Observable.Neverint(); // 4. 创建一个立即抛出错误的 Observable Observable.Throwint(new Exception(Error));2.2 从 Unity 事件创建csharp// 1. 从 Update 事件创建 Observable.EveryUpdate() .Subscribe(_ { // 每帧执行 }); // 2. 从 FixedUpdate 创建 Observable.EveryFixedUpdate() .Subscribe(_ { // 每个固定物理帧执行 }); // 3. 从协程创建 Observable.FromCoroutineint(observer CountCoroutine(observer, 5)) .Subscribe(count Debug.Log($Count: {count})); IEnumerator CountCoroutine(IObserverint observer, int count) { for (int i 0; i count; i) { observer.OnNext(i); yield return new WaitForSeconds(1); } observer.OnCompleted(); } // 4. 从 UnityEvent 创建 public UnityEvent myEvent; myEvent.AsObservable() .Subscribe(_ Debug.Log(Event triggered));2.3 从异步操作创建csharp// 1. 从 Task 创建 Observable.FromAsync(() SomeAsyncMethod()) .Subscribe(result Debug.Log(result)); async Taskstring SomeAsyncMethod() { await Task.Delay(1000); return Result; } // 2. 从 WWW/UnityWebRequest 创建 ObservableWWW.Get(http://example.com) .Subscribe( result Debug.Log(result), error Debug.LogError(error) );2.4 定时器相关csharp// 1. 定时器 Observable.Timer(TimeSpan.FromSeconds(1)) .Subscribe(_ Debug.Log(1秒后执行)); // 2. 间隔执行 Observable.Interval(TimeSpan.FromSeconds(1)) .Subscribe(tick Debug.Log($Tick: {tick})); // 3. 延迟执行 Observable.Start(() Debug.Log(Start)) .Delay(TimeSpan.FromSeconds(1)) .Subscribe();三、常用操作符3.1 转换操作符csharp// 1. Select - 映射转换 Observable.Range(1, 5) .Select(x x * 2) // 每个值乘以2 .Subscribe(x Debug.Log(x)); // 2, 4, 6, 8, 10 // 2. Where - 过滤 Observable.Range(1, 10) .Where(x x % 2 0) // 只保留偶数 .Subscribe(x Debug.Log(x)); // 2, 4, 6, 8, 10 // 3. Cast - 类型转换 ListGameObject objects new ListGameObject(); objects.AsObservable() .CastGameObject, Component() .Subscribe(component { /* 处理 */ });3.2 组合操作符csharp// 1. Merge - 合并多个流 var stream1 Observable.Interval(TimeSpan.FromSeconds(1)).Select(x $A{x}); var stream2 Observable.Interval(TimeSpan.FromSeconds(2)).Select(x $B{x}); stream1.Merge(stream2) .Subscribe(msg Debug.Log(msg)); // 2. Zip - 成对组合 Observable.Range(1, 3) .Zip(Observable.Range(10, 3), (a, b) ${a}-{b}) .Subscribe(pair Debug.Log(pair)); // 1-10, 2-11, 3-12 // 3. CombineLatest - 任意一个发射时使用最新值组合 var inputX GetAxisStream(Horizontal); var inputY GetAxisStream(Vertical); inputX.CombineLatest(inputY, (x, y) new Vector2(x, y)) .Subscribe(vector Move(vector)); // 4. Concat - 顺序连接 Observable.Return(First) .Concat(Observable.Return(Second)) .Subscribe(msg Debug.Log(msg)); // First, 然后 Second3.3 时间相关操作符csharp// 1. Throttle - 防抖一段时间内只取最后一个 inputField.OnValueChangedAsObservable() .Throttle(TimeSpan.FromSeconds(0.5)) .Subscribe(text Search(text)); // 2. Sample - 采样定期取最新值 Observable.EveryUpdate() .Sample(TimeSpan.FromSeconds(0.1)) .Subscribe(_ UpdatePer100ms()); // 3. Buffer - 缓冲 Observable.Interval(TimeSpan.FromSeconds(0.2)) .Buffer(TimeSpan.FromSeconds(1)) .Subscribe(buffer { Debug.Log($1秒内收到了 {buffer.Count} 个值); }); // 4. Timeout - 超时处理 GetDataFromServer() .Timeout(TimeSpan.FromSeconds(5)) .Subscribe( data Process(data), error { if (error is TimeoutException) Debug.Log(请求超时); } );3.4 错误处理操作符csharp// 1. Catch - 捕获错误并切换流 Observable.Throwint(new Exception(Error)) .Catch((Exception ex) { Debug.LogError(ex.Message); return Observable.Return(-1); }) .Subscribe(x Debug.Log(x)); // 输出 -1 // 2. Retry - 重试 GetNetworkData() .Retry(3) // 最多重试3次 .Subscribe( data Debug.Log(data), error Debug.LogError($失败: {error}) ); // 3. Finally - 最终执行 Observable.Createint(observer { // 创建资源 return Disposable.Create(() { // 清理资源 }); }) .Finally(() Debug.Log(最终清理)) .Subscribe();四、实际应用示例4.1 输入处理csharppublic class InputHandler : MonoBehaviour { void Start() { // 组合按键检测 var jumpStream Observable.EveryUpdate() .Where(_ Input.GetButtonDown(Jump)); var attackStream Observable.EveryUpdate() .Where(_ Input.GetMouseButtonDown(0)); jumpStream.Subscribe(_ Jump()); attackStream.Subscribe(_ Attack()); // 鼠标拖拽 var dragStream Observable.EveryUpdate() .Where(_ Input.GetMouseButton(0)) .Select(_ Input.mousePosition) .Pairwise() // 获取前后两个值 .Select(pair pair.Current - pair.Previous); dragStream.Subscribe(delta DragObject(delta)); } }4.2 UI 交互csharppublic class UIHandler : MonoBehaviour { public Button button; public InputField inputField; public Slider slider; public Toggle toggle; void Start() { // 按钮点击 button.OnClickAsObservable() .Subscribe(_ OnButtonClick()); // 输入框实时搜索 inputField.OnValueChangedAsObservable() .Throttle(TimeSpan.FromSeconds(0.3)) .Where(text text.Length 2) .DistinctUntilChanged() .Subscribe(Search); // 滑块值变化 slider.OnValueChangedAsObservable() .Subscribe(value UpdateValue(value)); // 开关状态 toggle.OnValueChangedAsObservable() .Subscribe(isOn ToggleFeature(isOn)); } }4.3 游戏逻辑csharppublic class HealthSystem : MonoBehaviour { public IntReactiveProperty currentHealth new IntReactiveProperty(100); public IObservablebool IsDead { get; private set; } public IObservablefloat HealthPercentage { get; private set; } void Start() { // 计算是否死亡 IsDead currentHealth .Select(health health 0) .DistinctUntilChanged(); // 计算血量百分比 HealthPercentage currentHealth .Select(health health / 100f); // 监听死亡事件 IsDead.Where(isDead isDead) .Subscribe(_ OnDeath()); // 低血量警告 currentHealth .Where(health health 30 health 0) .Subscribe(_ ShowLowHealthWarning()); } public void TakeDamage(int damage) { currentHealth.Value - damage; } }4.4 网络请求csharppublic class NetworkManager : MonoBehaviour { public IObservablestring DownloadData(string url) { return ObservableWWW.Get(url) .Timeout(TimeSpan.FromSeconds(10)) .Retry(3) .ObserveOnMainThread(); // 在主线程处理结果 } void LoadData() { DownloadData(http://api.example.com/data) .Subscribe( data { // 处理数据 ProcessData(JsonUtility.FromJsonData(data)); }, error { // 错误处理 if (error is TimeoutException) ShowMessage(请求超时); else ShowMessage(网络错误); } ); } }五、高级技巧5.1 自定义 Observablecsharppublic static class CustomObservables { // 自定义 Observable 扩展方法 public static IObservableVector3 MouseDragAsObservable(this Component component) { return Observable.CreateVector3(observer { bool isDragging false; Vector3 startPos Vector3.zero; var mouseDown Observable.EveryUpdate() .Where(_ Input.GetMouseButtonDown(0)) .Subscribe(_ { isDragging true; startPos Input.mousePosition; }); var mouseUp Observable.EveryUpdate() .Where(_ Input.GetMouseButtonUp(0)) .Subscribe(_ { isDragging false; }); var mouseDrag Observable.EveryUpdate() .Where(_ isDragging) .Select(_ Input.mousePosition - startPos) .Subscribe(observer); return Disposable.Create(() { mouseDown.Dispose(); mouseUp.Dispose(); mouseDrag.Dispose(); }); }); } }5.2 内存管理csharppublic class DisposableExample : MonoBehaviour { private CompositeDisposable disposables new CompositeDisposable(); void Start() { // 添加到 CompositeDisposable 统一管理 Observable.Interval(TimeSpan.FromSeconds(1)) .Subscribe(_ Debug.Log(Tick)) .AddTo(disposables); Observable.EveryUpdate() .Subscribe(_ { /* 更新逻辑 */ }) .AddTo(disposables); } void OnDestroy() { // 统一释放所有订阅 disposables.Dispose(); } }六、性能考虑及时释放订阅避免内存泄漏合理使用 Throttle/Sample减少不必要的处理避免频繁创建 Observable考虑重用使用合适的调度器注意线程切换开销总结UniRx 的 Observable 提供了强大的响应式编程能力特别适合处理 Unity 中的异步操作和事件流。通过合理使用各种操作符可以写出更简洁、可维护的代码。关键是要理解数据流的概念并掌握如何组合和转换这些流来满足不同的需求。