packages/shared/lib/helpers/listeners.ts

   1 export type Listener<Arguments extends any[], Return> = (...args: Arguments) => Return;
   2
   3 export interface Listeners<Arguments extends any[], Return> {
   4     notify: (...args: Arguments) => Return[];
   5     subscribe: (listener: Listener<Arguments, Return>) => () => void;
   6     clear: () => void;
   7     length: () => number;
   8 }
   9
  10 const createListeners = <Arguments extends any[], Return = void>(): Listeners<Arguments, Return> => {
  11     let listeners: Listener<Arguments, Return>[] = [];
  12
  13     const notify = (...args: Arguments) => {
  14         return listeners.map((listener) => {
  15             return listener(...args);
  16         });
  17     };
  18
  19     const subscribe = (listener: Listener<Arguments, Return>) => {
  20         listeners.push(listener);
  21         return () => {
  22             listeners.splice(listeners.indexOf(listener), 1);
  23         };
  24     };
  25
  26     const clear = () => {
  27         listeners = [];
  28     };
  29
  30     const length = () => listeners.length;
  31
  32     return {
  33         notify,
  34         subscribe,
  35         clear,
  36         length,
  37     };
  38 };
  39
  40 export default createListeners;