创建 observable 数据结构和 reactions(反应)

Atoms

在某些时候，你可能想要有更多的数据结构或其他可以在响应式计算中使用的东西(如流)。
要实现这个其实非常容易，使用 Atom 类即可。
Atom 可以用来通知 Mobx 某些 observable 数据源被观察或发生了改变。
当数据源被使用或不再使用时，MobX 会通知 atom 。

下面的示例演示了如何创建一个 observable Clock，它可以用在响应式函数中，并且返回当前时间。
这个 clock 只有当它被观察了才会运行。

此示例演示了 Atom 类的完整API。

import {Atom, autorun} from "mobx";
class Clock {
    atom;
    intervalHandler = null;
    currentDateTime;
    constructor() {
        // 创建一个 atom 用来和 MobX 核心算法交互
        this.atom =    new Atom(
            // 第一个参数: atom 的名字，用于调试
            "Clock",
            // 第二个参数(可选的): 当 atom 从未被观察到被观察时的回调函数
            () => this.startTicking(),
            // 第三个参数(可选的): 当 atom 从被观察到不再被观察时的回调函数
            // 注意同一个 atom 在这两个状态之间转换多次
            () => this.stopTicking()
        );
    }
    getTime() {
        // 让 MobX 知道这个 observable 数据源已经使用了
        // 如果 atom 当前是被某些 reaction 观察的，那么 reportObserved 方法会返回 true
        // 如果需要的话，reportObserved 还会触发 onBecomeObserved 事件处理方法(startTicking)
        if (this.atom.reportObserved()) {
      return this.currentDateTime;
    } else {
            // 显然 getTime 被调用的同时并没有 reaction 正在运行
            // 所以，没有人依赖这个值，因此 onBecomeObserved 处理方法(startTicking)不会被触发
            // 根据 atom 的性质，在这种情况下它可能会有不同的表现(像抛出错误、返回默认值等等)
        return new Date();
    }
    }
    tick() {
        this.currentDateTime = new Date();
        // 让 MobX 知道这个数据源发生了改变
        this.atom.reportChanged();
    }
    startTicking() {
        this.tick(); // 最初的运行
        this.intervalHandler = setInterval(
            () => this.tick(),
            1000
        );
    }
    stopTicking() {
        clearInterval(this.intervalHandler);
        this.intervalHandler = null;
    }
}
const clock = new Clock();
const disposer = autorun(() => console.log(clock.getTime()));
// ... 输出每一秒的时间
disposer();
// 停止输出。如果没有人使用同一个 `clock` 的话，clock 也将停止运行。

Reactions(反应)

Reaction 允许你创建你自己的 自动运行器。
当函数应该再次执行时， Reaction 会追踪函数和信号，因为一个或多个依赖关系已更改。

这是 autorun 如何使用 Reaction 来定义的:

export function autorun(view: Lambda, scope?: any) {
    if (scope)
        view = view.bind(scope);
    const reaction = new Reaction(view.name || "Autorun", function () {
        this.track(view);
    });
    // 运行刚刚创建的 reaction 或将其列入计划表中
    if (isComputingDerivation() || globalState.inTransaction > 0)
        globalState.pendingReactions.push(reaction);
    else
        reaction.runReaction();
    return reaction.getDisposer();
}