dj-event-store

An event-bus and store tools

一个事件总线工具,一个全局状态管理工具

补充说明

• 事件总线工具基于 Map
• 全局状态管理工具基于 Proxy

如何使用呢？

1、npm 安装依赖

npm install dj-event-store

2、事件总线（event-bus）

const { DJEventBus } = require("dj-event-store");

const eventBus = new DJEventBus();

const whyCallback1 = (...payload) => {
  console.log("whyCallback1:", payload);
};

const whyCallback2 = (...payload) => {
  console.log("whyCallback1:", payload);
};

const lileiCallback1 = (...payload) => {
  console.log("lileiCallback1:", payload);
};

eventBus.on("why", whyCallback1);
eventBus.on("why", whyCallback2);
eventBus.on("lilei", lileiCallback1);
eventBus.once("why", (...payload) => {
  console.log("why once:", payload);
});

setTimeout(() => {
  eventBus.emit("why", "abc", "cba", "nba");
  eventBus.emit("lilei", "abc", "cba", "nba");
}, 1000);

setTimeout(() => {
  eventBus.off("why", whyCallback1);
  eventBus.off("lilei", lileiCallback1);
}, 2000);

setTimeout(() => {
  eventBus.emit("why");
  eventBus.emit("lilei");
}, 3000);

3、数据共享（event-store）

const { DJEventStore } = require("dj-event-store");

const eventStore = new DJEventStore({
  state: {
    name: "why",
    friends: ["abc", "cba", "nba"],
    banners: [],
    recommends: [],
  },
  actions: {
    getHomeMultidata(ctx) {
      new Promise((resolve) => {
        setTimeout(() => {
          resolve();
        }, 2000);
      }).then((_) => {
        ctx.banners = ["banners"];
        ctx.recommends = ["recommends"];
      });
    },
  },
});

// 数据监听
eventStore.onState("name", (value) => {
  console.log("监听name:", value);
});

eventStore.onState("friends", (value) => {
  console.log("监听friends:", value);
});

eventStore.onState("banners", (value) => {
  console.log("监听banners:", value);
});

eventStore.onState("recommends", (value) => {
  console.log("监听recommends", value);
});

// 数据变化
setTimeout(() => {
  eventStore.setState("name", "lilei");
  eventStore.setState("friends", ["kobe", "james"]);
}, 1000);

eventStore.dispatch("getHomeMultidata");