bufferEvents.ts

export function bufferStream(
  handler: (events: Event[]) => void,
  timeMs: number,
): (event: Event) => void {
  let timeout: number = null;
  let events: Event[] = [];
  return (event: Event) => {
    if (timeout != null) {
      clearTimeout(timeout);
    }
    events.push(event);
    timeout = setTimeout(() => {
      handler(events);
      events = [];
    }, timeMs);
  };
}