pgadmin4/web/pgadmin/static/js/helpers/EventBus.js

import _ from 'lodash';

export default class EventBus {
  constructor() {
    this._eventListeners = [];
  }

  registerListener(event, callback, once=false) {
    this._eventListeners = this._eventListeners || [];
    this._eventListeners.push({
      event: event,
      callback: callback,
      fired: once ? 'pending' : 'ignore',
    });
  }

  on(...args) {
    this.registerListener(...args);
  }

  once(...args) {
    this.registerListener(...args, true);
  }

  deregisterListener(event, callback) {
    if(callback) {
      this._eventListeners = this._eventListeners.filter((e)=>{
        if(e.event === event) {
          return e.callback.toString()!=callback.toString();
        }
        return true;
      });
    } else {
      this._eventListeners = this._eventListeners.filter((e)=>e.event!=event);
    }
  }

  off(...args) {
    this.deregisterListener(...args);
  }

  fireEvent(event, ...args) {
    let self = this;
    Promise.resolve(0).then(()=>{
      let allListeners = _.filter(this._eventListeners, (e)=>e.event==event);
      if(allListeners) {
        for(const listener of allListeners) {
          Promise.resolve(0).then(()=>{
            listener.callback(...args);
            if(listener.fired == 'pending') {
              self.deregisterListener(event, listener.callback);
            }
          });
        }
      }
    });
  }

  trigger(...args) {
    this.fireEvent(...args);
  }
}