RxJS通过Observable实现数据流管理，核心包括可观察对象、观察者、操作符和Subject，利用函数式编程处理异步事件流，需注意资源释放以避免内存泄漏。
函数式反应编程（FRP）在JavaScript中通过库如RxJS实现，其核心是将随时间变化的数据流抽象为可观察的序列，并利用函数式编程的思想来处理这些数据流。RxJS的核心概念围绕“响应变化”和“数据流管理”展开，以下是几个关键点：
Observable（可观察对象）
Observable 是 RxJS 的基础。它代表一个异步数据流，可以 emit 多个值，也可能出错或完成。与 Promise 只能 resolve 一次不同，Observable 支持多次 emit 值，适合处理事件、定时任务等连续发生的数据。
例如：用户输入、HTTP 请求、鼠标点击都可以被封装成 Observable。Observer（观察者）
Observer 是订阅 Observable 的对象，包含三个回调函数：next、error 和 complete。当 Observable 发出值时，next 被调用；出现错误时调用 error；结束后调用 complete。
这种模式实现了发布-订阅机制，让数据消费者被动接收更新。Operators（操作符）
Operators 是纯函数，用于对 Observable 流进行转换、过滤、合并等操作。它们不修改原始流，而是返回新的 Observable，体现函数式编程的不可变性。
立即学习“Java免费学习笔记（深入）”；
常见操作符包括：- map：转换每个发出的值
- filter：只保留满足条件的值
- debounceTime：防抖，常用于搜索输入
- switchMap：切换到新的 Observable，取消旧请求
Subject（主体）
Subject 是一种特殊类型，既是 Observable 又是 Observer。它可以同时被订阅，也能主动 emit 值，适合广播场景。
BehaviorSubject、ReplaySubject 和 AsyncSubject 扩展了 Subject，提供初始值、重放历史或延迟发送等功能。基本上就这些。RxJS 通过组合 Observable 和操作符，让异步逻辑更清晰、更易维护。理解这些核心概念后，就能高效处理复杂的事件流和状态变化。不复杂但容易忽略的是，资源管理也很重要——记得在不需要时 unsubscribe，避免内存泄漏。
