束ね配信は、毎正時に列を空にするだけで作れる

1type Notice = { id: string; from: string; at: Date };

2

3const HOUR = 60 * 60 * 1000;

4const queue: Notice[] = [];

5

6// 届いた通知は渡さずに、列にためる

7export function receive(n: Notice) {

8 queue.push(n);

9}

10

11export function startBatching(deliver: (ns: Notice[]) => void) {

12 const wait = HOUR - (Date.now() % HOUR);1

13 setTimeout(() => {

14 deliver(queue.splice(0));2

15 setInterval(() => deliver(queue.splice(0)), HOUR);3

16 }, wait);

17}