FSharp.Idioms.Reactive 0.0.1

FSharp.Idioms.Reactive

System.Reactive 的 F# 惯用（Idioms）工具库，独立于 WPF、可跨平台复用（目标框架 netstandard2.0）。本库是 FSharp.ReactiveWpf 响应式绑定工具集中与 UI 无关的公共核心，提供可观察数组、Subject 与 BehaviorSubject 的常用便捷操作。

项目标题：System.Reactive 惯常用法库 版本：0.0.1　·　许可证：LGPL-3.0-or-later　·　作者：xp44mm

特性

• 可观察数组（ObservableArray）：像 Panel.Children 一样增删元素，变更以 IObservable 流对外广播；元素与 IDisposable 句柄平行存放，删除即自动释放，整体 Dispose 即聚合释放器。
• 去重推送（BehaviorSubject.tryNext 系列）：仅在“值确实变化”时才调用 OnNext，避免无意义的重复通知（支持自定义相等、阈值、四舍五入三种策略）。
• 纯 System.Reactive、零 WPF 依赖：可在控制台、服务端、测试及任意 .NET 平台复用。

引用

项目引用（推荐）

在另一个 .fsproj 中添加：

<ItemGroup>
  <ProjectReference Include="..\FSharp.Idioms.Reactive\FSharp.Idioms.Reactive.fsproj" />
</ItemGroup>

NuGet

发布后通过包 ID FSharp.Idioms.Reactive 引用（当前版本 0.0.1，PackageTags: fsharp;reactive;rx）。

模块 API

ObservableArray —— 可观察数组

命名空间 FSharp.Idioms.Reactive 下提供两个类型。

变更通知 UIElementCollectionChange<'T>

镜像 System.Windows.Controls.UIElementCollection（Panel.Children）的增删操作，命名与参数输入严格对齐：

ObservableArray<'T>

示例：

open System
open System.Reactive.Disposables
open FSharp.Idioms.Reactive

let array = new ObservableArray<string>()

// 订阅变更通知
use sub =
    array.Changes.Subscribe(fun change ->
        printfn "%A" change)

array.Add("a", Disposable.Empty)              // 广播 Add "a"
array.AddRange [ "b", Disposable.Empty        // 广播 AddRange ["b"; "c"]
                 "c", Disposable.Empty ]
array.Insert(0, "x", Disposable.Empty)        // 广播 Insert(0, "x")
array.RemoveAt(1)                             // 广播 RemoveAt 1，并释放该位置句柄
array.Clear()                                 // 广播 Clear，并释放全部句柄

提示：ObservableArray 的 Item 只有 getter，修改请通过 RemoveAt + Insert，与 UIElementCollection 语义一致。

Subject —— 便捷推送

模块 FSharp.Idioms.Reactive.Subject：

BehaviorSubject —— 去重推送

模块 FSharp.Idioms.Reactive.BehaviorSubject。BehaviorSubject 会缓存最近值，以下辅助函数都遵循同一约定：仅在“新值相对当前值确实不同”时调用 OnNext，相同则不推送，用于避免触发无意义的级联更新。

示例：

open System.Reactive.Subjects
open FSharp.Idioms.Reactive.BehaviorSubject

let bs = new BehaviorSubject<float>(0.0)

tryNext 1.0 bs    // 0.0 -> 1.0，推送
tryNext 1.0 bs    // 值未变，不推送

tryNextDelta 0.01 1.005 bs   // 差值 0.005 <= 0.01，不推送
tryNextDelta 0.01 1.011 bs   // 差值 0.011 >  0.01，推送

tryNextRound 2 1.2346 bs     // 舍入后 1.23 = 1.23，不推送
tryNextRound 2 1.2350 bs     // 舍入后 1.23 <> 1.24，推送

设计要点

• UI 无关的分层：本库只依赖 System.Reactive（v7.0.0），所有“控件绑定”逻辑都在上层库 FSharp.ReactiveWpf 中；需要 WPF 绑定时组合两者，纯逻辑场景只引用本库。
• 生命周期集中管理：ObservableArray 把元素与 IDisposable 句柄平行存放，删除即释放、整体 Dispose 即聚合释放器，避免订阅/句柄泄漏。
• 变更通知与 UIElementCollection 对齐：变更类型命名与参数输入镜像 Panel.Children 的增删操作，便于把响应式数组直接驱动 UI 集合。
• 减少无效通知：BehaviorSubject.tryNext 系列把“是否值得推送”的判断收敛到一处，默认结构相等、可自定义阈值与精度。

测试

FSharp.ReactiveWpf.Test 项目中的 BehaviorSubjectTest.fs 覆盖：

• tryNext：值相等不更新、值不等更新；
• tryNextDelta：差值大于阈值才更新（<= delta 不更新）；
• tryNextRound：四舍五入后不同才更新；
• tryNextRound 负数 decimals 抛出 ArgumentOutOfRangeException。

运行：dotnet test FSharp.ReactiveWpf.Test

相关项目

• FSharp.ReactiveWpf：WPF 响应式绑定工具库，本库是其与 UI 无关的公共核心依赖。

许可证

LGPL-3.0-or-later