sbee - Simple Buffered Event Emitter

This project is a simple implementation of a event emitter, but with one particularity: you can create buffers to only emit the events when some condition occurs. Like a relational database transaction, but for events. Like this:

const { BufferedEventEmitter } = require("sbee");

// Create an instance of the event emiter
const instance = new sbee.BufferedEventEmitter();

// Now you can register handlers to your events:
// Every event of the type "the-event" will call this function.
// If the event is emitted inside a buffer, those calls will only be made when the buffer is flushed
instance.subscribe("the-event", data => console.log(data));


// You can emit an event to call the handler right away:
instance.emit("the-event", 1); // will call the handler and log 1 on the console

// Or you can do it inside a buffer
// Create your buffer
// Context is some information that you may need to know on your handlers.
// The name of the buffer must be unique. You can use a uniqid, for example, but you need to keep track of it
instance.createBuffer("my buffer", { my: "context" });

// Now you emit the event inside the buffer
instance.emitBuffered("my buffer", "the-event", { the: "data" });
// Another one, maybe
instance.emitBuffered("my buffer", "the-event", { the: "data2" });

// You need to flush to "really" emit all those events from the buffer
instance.flush("my buffer"); // wil lcal the handler 2 times, cause we emitted 2 events

// You can delete all the events too
instance.cleanBuffer("my buffer");

Docs: https://beeblebrox3.github.io/sbee/

License