hostbbq-monitoring/ng/src/app/lib/indexed-subject.class.ts

import { PartialObserver, ReplaySubject } from 'rxjs';

export class IndexedReplaySubject<K, T> {
  private index: Map<K, ReplaySubject<T>> = new Map();

  get(key: K): ReplaySubject<T> {
    let sub = this.index.get(key);
    if (!sub) {
      sub = new ReplaySubject(1);
      this.index.set(key, sub);
    }
    return sub;
  }

  next(key: K, value: T) {
    this.get(key).next(value);
  }
}