Skip to main content
Home

Built and signed on GitHub Actions

A simple message bus used for swapping out formatting for messages in cli applications. This module exists primarily for the rt ("run-task") cli.

This package works with Cloudflare Workers, Node.js, Deno, Bun, Browsers
This package works with Cloudflare Workers
This package works with Node.js
This package works with Deno
This package works with Bun
This package works with Browsers
JSR Score
70%
Published
a year ago (0.0.0)

@rt/message-bus

logo Work less. Do more.

Overview

A simple message bus used for swapping out formatting for messages in cli applications. This module exists primarily for the rt ("run-task") cli.

Basic Usage

import { Message, DefaultMessageBus } from str from '@rt/message-bus'

const bus = new DefaultMessageBus();

export class WriteMessage extends Message {
    constructor(public message: string) {
        super("write")
    }
}

const messages: Message[] = [];
bus.addListener((message) => {
    messages.push(message);
});

bus.send(new WriteMessage("test"));

console.log(messages.length);
console.log(messages[0].kind);
console.log((messages[0] as WriteMessage).message);

MIT License

Built and signed on
GitHub Actions

New Ticket: Report package

Please provide a reason for reporting this package. We will review your report and take appropriate action.

Please review the JSR usage policy before submitting a report.

Add Package

deno add jsr:@rt/message-bus

Import symbol

import * as message_bus from "@rt/message-bus";
or

Import directly with a jsr specifier

import * as message_bus from "jsr:@rt/message-bus";

Add Package

pnpm i jsr:@rt/message-bus
or (using pnpm 10.8 or older)
pnpm dlx jsr add @rt/message-bus

Import symbol

import * as message_bus from "@rt/message-bus";

Add Package

yarn add jsr:@rt/message-bus
or (using Yarn 4.8 or older)
yarn dlx jsr add @rt/message-bus

Import symbol

import * as message_bus from "@rt/message-bus";

Add Package

vlt install jsr:@rt/message-bus

Import symbol

import * as message_bus from "@rt/message-bus";

Add Package

npx jsr add @rt/message-bus

Import symbol

import * as message_bus from "@rt/message-bus";

Add Package

bunx jsr add @rt/message-bus

Import symbol

import * as message_bus from "@rt/message-bus";