Zen Bus ☮️

A simple event bus for your general pub/sub needs.

installation

yarn add @zenstack/zen-bus

or

npm install @zenstack/zen-bus

Usage

Create An Event Bus

import { createEventBus } from "@zenstack/zen-bus";
const eventBus = createEventBus();

//you can also use a class if you are an OO person
import { EventBus } from "@zenstack/zen-bus";
const eventBus = new EventBus();

Subscribe To Particular Event

To subscribe a handler to an event type, you can use the .subscribe(:eventType, :handler) method.

const myTodoList = ['Clean Toilet'];
const addToList = (event) => myTodoList.push(event.title);
const logEvent = (event) => console.log(event);

eventBus.subscribe('Todo Added', addToList);
eventBus.subscribe('Todo Added', logEvent);

Subscribe To Any Event

If you would like to subscribe a handler to any event type, you can use the EventBus's ANY_EVENT_TYPE static property.

import { EventBus } from "@zenstack/zen-bus";

const logEvent = (event) => console.log(event);

// this will trigger `logEvent` when any event is emitted.
eventBus.subscribe(EventBus.ANY_EVENT_TYPE, addToList);

Emit An Event

An event is an object that contains a string type attribute. You can asynchronously emit an event by using the event bus's .emit(:event) method.

const todoAddedEvent = {
    type: 'Todo Added',
    title: 'Clean the kitchen'
};

eventBus.emit(todoAddedEvent);

Emit An Event Synchronously

By default, events are emitted asynchronously. You can also force the emission to be synchronous if you'd like.

const todoAddedEvent = {
    type: 'Todo Added',
    title: 'Clean the kitchen'
};

eventBus.emitSync(todoAddedEvent);

Note: Be careful of emitting events synchronously. It has a few disadvantages:

• It locks up the thread up until all handlers have been executed
• Strange sequences may occur if you decide to emit another event as part of another event's handler. Just don't do this synchronously... you have been warned.

Unsubscribe Handlers of Particular Event

If at any point you would like to unsubscribe all handlers of a particular event type, you can use the event bus's .flush(:eventType) method.

const myEvent1 = { type: 'myEvent1' };
const myEvent2 = { type: 'myEvent2'};

const myHandler1 = (event) => {/*..*/};
const myHandler2 = (event) => {/*..*/};
const myHandler3 = (event) => {/*..*/};

eventBus.subscribe('myEvent1', myHandler1);
eventBus.subscribe('myEvent1', myHandler2);
eventBus.subscribe('myEvent2', myHandler3);

// will trigger all event handlers
eventBus.emit(myEvent1);
eventBus.emit(myEvent2);

// only myHandler3 is still subscribed. only it will be triggered.
eventBus.flush('myEvent1');
eventBus.emit(myEvent1);
eventBus.emit(myEvent2);

Unsubscribe All Handlers

If at any point you would like to unsubscribe all handlers, you can use the event bus's .flushAll() method.

const myEvent1 = { type: 'myEvent1' };
const myEvent2 = { type: 'myEvent2'};

const myHandler1 = (event) => {/*..*/};
const myHandler2 = (event) => {/*..*/};
const myHandler3 = (event) => {/*..*/};

eventBus.subscribe('myEvent1', myHandler1);
eventBus.subscribe('myEvent1', myHandler2);
eventBus.subscribe('myEvent2', myHandler3);

// will trigger all event handlers
eventBus.emit(myEvent1);
eventBus.emit(myEvent2);

// no handler is susbcribed. Non will trigger.
eventBus.flushAll();
eventBus.emit(myEvent1);
eventBus.emit(myEvent2);