@eventkit/base

@eventkit/base is the primary package in the eventkit project.

Installation

npm i @eventkit/base

Basic Example

This is a basic example of how to use an eventkit stream. To get started, you should check out the Getting Started guide.

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();

Related Resources

• eventkit
• Getting Started
• API Reference
• Changelog