RX-MBT

#作为三方依赖使用

#方式一：git 依赖（无需发布到中心仓库）

# 在你的项目里执行（仓库地址替换为实际 git 地址）
moon add git+https://<你的仓库地址>.git

import {
  "vicTop-cw/RX-MBT/rx" @rx,
}

#方式二：发布到 MoonBit 中心仓库

moon publish
# 之后任何项目可用：
moon add vicTop-cw/RX-MBT

#使用示例（外部项目视角）

// moon.pkg 中已 import "vicTop-cw/RX-MBT/rx" @rx
fn main {
  // 链式调用：map -> filter -> collect
  let result = @rx.Observable::from_iter([1, 2, 3, 4, 5])
    .map(fn(x) { x * 2 })
    .filter(fn(x) { x > 4 })
  let _ = result.subscribe_on_next(fn(v) { println(v) })

  // Subject 多播
  let subject : @rx.PublishSubject[Int, Unit] = @rx.PublishSubject::new()
  let _ = subject.subscribe(@rx.Observer::on_next_only(fn(v) { println("收到: \{v}") }))
  subject.on_next(42)
  subject.on_completed()
}

#启动与测试

moon check      # 类型检查（零警告零错误）
moon test       # 运行全部测试

完整的 API 签名与语义说明见 DOC.md（按分类整理的全部公开 API）。

#版本与测试环境

工具链版本以 moon version 输出为准。要求 moon >= 0.1.20260724（本项目使用了较新的 moon.mod / moon.pkg 语法与 Feature flags：rr_moon_mod, rr_moon_pkg）。

#测试报告

powershell -ExecutionPolicy Bypass -File scripts/gen_test_report.ps1

moon test -p test-suit/bench --include-skipped > moon_bench.json

#核心抽象

#Itor / Node（可控制迭代器）

#创建类工厂

#操作符

#Subject（多播主题）

#调度器

#示例

// 链式调用：map -> filter -> collect
let result = Observable::from_iter([1, 2, 3, 4, 5])
  .map(fn(x) { x * 2 })
  .filter(fn(x) { x > 4 })
  .collect()
let _ = result.subscribe_on_next(fn(v) { println(v) })

// Subject 多播
let subject : PublishSubject[Int, Unit] = PublishSubject::new()
let _ = subject.subscribe_on_next(fn(v) { println("收到: \{v}") })
subject.on_next(42)
subject.on_completed()

#与 Rx-Rust 的差异

• 监控类 API（文件/文件夹监听、watch_file / watch_folder 等）未移植
• 时间类操作符基于虚拟时钟而非真实定时器，测试时用 advance_time(ms) 推进
• 背压与线程池调度器在同步模型下为签名占位，语义等价透传/立即执行