event-aggregated-comsumer.ts

class Consumer<R> {
  subscribe<T extends abstract new (...args: any) => any>(event: T, map: (event: InstanceType<T>) => R): Consumer<R> {
    return this;
  }
  connect(): Consumer<R> {
    return this;
  }
  handle(handler: (event: R) => any): Consumer<R> {
    //asdasa
    return this;
  }
}

const consumer = new Consumer<{ guid: string }>()
  .subscribe(PaymentOrderEvents.Created, ({ guid }) => ({ guid }))
  .subscribe(PaymentOrderEvents.Processing, ({ guid }) => ({ guid }))
  .subscribe(PaymentOrderEvents.Completed, ({ guid }) => ({ guid }))
  .subscribe(PaymentOrderEvents.Canceled, ({ guid }) => ({ guid }))
  .subscribe(PaymentOrderEvents.Failed, ({ guid }) => ({ guid }))
  .subscribe(PaymentOrderEvents.Expired, ({ guid }) => ({ guid }))
  .subscribe(PaymentOrderEvents.Expired, ({ guid }) => ({ guid }))
  .connect()
  .handle(({ guid }) => {
    console.log({ guid });
  });