Publisher-Subscriber Pattern

Publisher-Subscriber.js

const pubSub = (() => {
    const topicSubscriberMap = new Map();
    const throwError = (topic) => {
        throw new Error(`
            No ${topic} named topic found in the registry.
            Available topics:- ${JSON.stringify(getAllTopic())}
        `);
    };
    const getAllTopic = () => Array.from(topicSubscriberMap.keys());
    const createTopic = (topic) => {
        if (topicSubscriberMap.get(topic)) throw new Error("Topic is already registered.");
        topicSubscriberMap.set(topic, []);
        return  1;
    };
    const publish = (topic, data) => {
        if (topicSubscriberMap.has(topic)) {
            const subscribers = topicSubscriberMap.get(topic) || [];
            subscribers.forEach(subscriberCb => subscriberCb && subscriberCb(data));
            return 1;
        }
        throwError(topic);
    };
    const subscribe = (topic, cb) => {
        if (topicSubscriberMap.has(topic)) {
            const subscribers = topicSubscriberMap.get(topic) || [];
            subscribers.push(cb);
            topicSubscriberMap.set(topic, subscribers);
            return 1;
        }
        throwError(topic);
    }
    const unSubscribe = (topic, cb) => {
        if (topicSubscriberMap.has(topic)) {
            let subscribers = topicSubscriberMap.get(topic) || [];
            subscribers = subscribers.filter(subscriberCb => subscriberCb !== cb);
            topicSubscriberMap.set(topic, subscribers);
            return 1;
        }
        throwError(topic);
    };

    return {
        publisher: {
            publish,
            createTopic
        },
        subscriber: {
            unSubscribe,
            subscribe
        },
        getAllTopic
    };
})()
/**
const callback1 = (data) => console.log("callback1 click", data);
const callback2 = (data) => console.log("callback2 click", data);
const callback3 = (data) => console.log("callback3 keydown", data);
const callback4 = (data) => console.log("callback4 both", data);


pubSub.publisher.createTopic("click");
pubSub.subscriber.subscribe("click", callback1);
pubSub.subscriber.subscribe("click", callback2);

pubSub.publisher.publish("click", "click happen")
pubSub.subscriber.unSubscribe("click", callback2)
pubSub.publisher.publish("click", "another click happen")


pubSub.publisher.createTopic("keydown");


pubSub.subscriber.subscribe("click", callback3);
pubSub.subscriber.subscribe("click", callback4);
pubSub.subscriber.subscribe("click", callback4);

pubSub.subscriber.subscribe("keydown", callback3);
pubSub.subscriber.subscribe("keydown", callback4);


pubSub.publisher.publish("click", "click")
pubSub.publisher.publish("keydown", "keydown")
**/

Difference between observer vs pub-sub pattern
In the Observer Pattern, the Subject and observer know each other. Subject maintains a list of all the observer and call when needed
In the Pub-Sub Pattern, publishers and subscribers do not know each other.
The subscriber subscribes topic and publishers publish data on the topic.
So topic handlers know each topic and their respective subscribers.

Implementation of observer link here