import * as plugins from './smartuniverse.plugins.js';

/**
 * broadcasts an event to multiple channels
 * also handles subscription
 */
export class BroadcastEvent<T extends plugins.typedrequestInterfaces.ITypedEvent<any>> {
  public eventSubject = new plugins.smartrx.rxjs.Subject<T['payload']>();

  constructor() {}

  public fire(eventPayloadArg: T['payload']) {}

  public subscribe(funcArg: (nextArg: T['payload']) => void): plugins.smartrx.rxjs.Subscription {
    return this.eventSubject.subscribe(funcArg);
  }
}