Publish-Subscribe на TypeScript — уменьшаем связанность

Нередко обхожусь одним только редисом

https://redis.io/topics/pubsub

Найс пет-проджект, RxJS на минималках.

Хоть PubSub можно и самому написать за 5 минут без лишних выкрутасов:

class Observer<T = any> {
  private subs: Subscriber[] = [];

  subscribe(sub: Subscriber<T>): Unsubscribe {
    this.subs.push(sub);

    return () => {
      this.subs = this.subs.filter((item) => item !== sub);
    };
  }

  publish(...args: T[]): void {
    this.subs.forEach((sub) => {
      sub(...args);
    });
  }
}

type Subscriber<T = any> = (...args: T[]) => void;
type Unsubscribe = () => void;

// Client code example
const observer = new Observer<number>();

const unsubscribe = observer.subscribe((num) => {
  console.log(num);
});

observer.publish(42); // 42

unsubscribe();

observer.publish(666); // -