Function TestGetTimelineCount

pkg/events/bus_test.go:241–256

TestGetTimelineCount 测试获取事件数量

(t *testing.T)

// TestGetTimelineCount 测试获取事件数量
func TestGetTimelineCount(t *testing.T) {
	eb := NewEventBus()
	defer eb.Close()

	if eb.GetTimelineCount() != 0 {
		t.Error("initial count should be 0")
	}

	for i := range 10 {
		eb.EmitProgress(&types.ProgressTextChunkEvent{Step: i, Delta: "test"})
	}

	if eb.GetTimelineCount() != 10 {
		t.Errorf("expected count 10, got %d", eb.GetTimelineCount())
	}
}

// TestAutoCleanupWorker 测试自动清理 worker
func TestAutoCleanupWorker(t *testing.T) {