PubSub.Broker

import { PubSub } from "https://raw.githubusercontent.com/i-xi-dev/pubsub.es/2.0.17/mod.ts"; 

const { Broker } = PubSub;

The message broker.

class Broker<T> {

constructor();

clear(): void;

async publish(topic: Topic, message: T): Promise<void>;

subscribe(

topic: Topic,

callback: (message: T) => Promise<void>,

): void;

unsubscribe(topic: Topic, callback: (message: T) => Promise<void>): void;

}

§Type Parameters

new Broker()

clear(): void

Clears all subscriptions and all topics.

publish(topic: Topic, message: T): Promise<void>

Sends a message to the topic.

@param topic

@param message

unsubscribe(topic: Topic, callback: (message: T) => Promise<void>): void

Unsubscribe from the topic.

@param topic

@param callback