Function TestMemoryStability

pkg/events/bus_test.go:283–324

TestMemoryStability 测试内存稳定性（防止泄漏）

(t *testing.T)

// TestMemoryStability 测试内存稳定性（防止泄漏）
func TestMemoryStability(t *testing.T) {
	config := &EventBusConfig{
		MaxTimelineSize: 1000,
		MaxTimelineAge:  0,
		CleanupInterval: 50 * time.Millisecond,
	}
	eb := NewEventBusWithConfig(config)
	defer eb.Close()

	// 分批发送事件，给清理 worker 时间工作
	batches := 100
	eventsPerBatch := 100

	for batch := range batches {
		// 快速发送一批事件
		for i := range eventsPerBatch {
			eb.EmitProgress(&types.ProgressTextChunkEvent{
				Step:  batch*eventsPerBatch + i,
				Delta: "test data",
			})
		}

		// 每批之后给清理 worker 一些时间
		if batch%10 == 0 {
			time.Sleep(100 * time.Millisecond)
			count := eb.GetTimelineCount()
			// 应该在合理范围内
			if count > 1500 {
				t.Errorf("timeline growing too large: %d at batch %d", count, batch)
			}
		}
	}

	// 等待最后一次清理
	time.Sleep(200 * time.Millisecond)

	// 最终检查
	finalCount := eb.GetTimelineCount()
	if finalCount > 1100 {
		t.Errorf("final timeline count too large: %d (expected <= 1100)", finalCount)
	}
}

// TestUnsubscribeMultipleChannels 测试多通道取消订阅
func TestUnsubscribeMultipleChannels(t *testing.T) {