coalescer_test.go RawHistoryFolder

1package mainloop
2
3import "testing"
4
5func TestCoalescerMergesBurstIntoSingleIdle(t *testing.T) {
6	queue := make([]func(), 0, 8)
7	c := NewCoalescer(func(fn func()) { queue = append(queue, fn) })
8
9	value := 0
10	for i := 1; i <= 5; i++ {
11		v := i
12		c.Post("omnibox-search", func() { value = v })
13	}
14
15	if len(queue) != 1 {
16		t.Fatalf("expected 1 scheduled callback, got %d", len(queue))
17	}
18	queue[0]()
19
20	if value != 5 {
21		t.Fatalf("expected latest callback to run, got %d", value)
22	}
23}
24
25func TestCoalescerDropsWorkAfterDestroy(t *testing.T) {
26	queue := make([]func(), 0, 4)
27	c := NewCoalescer(func(fn func()) { queue = append(queue, fn) })
28
29	ran := false
30	c.Post("ghost-clear", func() { ran = true })
31	c.Destroy()
32
33	if len(queue) != 1 {
34		t.Fatalf("expected one queued callback before destroy, got %d", len(queue))
35	}
36	queue[0]()
37
38	if ran {
39		t.Fatalf("expected queued work to be dropped after destroy")
40	}
41
42	c.Post("ghost-clear", func() { ran = true })
43	if len(queue) != 1 {
44		t.Fatalf("expected no new callback after destroy, got %d", len(queue))
45	}
46}
47
48func TestNewCoalescerPanicsOnNilPost(t *testing.T) {
49	defer func() {
50		if r := recover(); r == nil {
51			t.Fatalf("expected NewCoalescer to panic when post is nil")
52		}
53	}()
54
55	_ = NewCoalescer(nil)
56}