@eventkit/base 是 eventkit 项目中的主包.
安装
npm i @eventkit/base
使用 CDN 软件
此软件包还捆绑了一个方便浏览器的版本,可以使用类似 CDN 的 CDN 访问 (单位:公斤)。 。 。 .
<!-- Development -->
<script src="https://unpkg.com/@eventkit/base/dist/index.global.js"></script>
<!-- Minified -->
<script src="https://unpkg.com/@eventkit/base/dist/index.global.min.js"></script>
进口时,所有出口都可以在 eventkit 全球变量.
const { Stream, filter } = eventkit;
基本示例
这是如何使用事件溪流的基本例子. 要开始,你应该看看 开始 向导.
import { Stream, filter } from "@eventkit/base";
// Create a stream of events
const stream = new Stream<{ type: string; payload: any }>();
// Filter for specific event types
const userEvents = stream.pipe(filter((event) => event.type.startsWith("user.")));
// Subscribe to the filtered stream
userEvents.subscribe((event) => {
console.log(`Received user event: ${event.type}`);
});
// Push events to the stream
stream.push({ type: "user.login", payload: { userId: "123" } });
stream.push({ type: "system.update", payload: { version: "1.0.1" } }); // This won't be logged
// Wait for all events to be processed
await stream.drain();