Function TestGetTimelineSince

pkg/events/bus_test.go:202–216

TestGetTimelineSince 测试从指定 cursor 后获取事件

(t *testing.T)

// TestGetTimelineSince 测试从指定 cursor 后获取事件
func TestGetTimelineSince(t *testing.T) {
	eb := NewEventBus()
	defer eb.Close()

	// 添加事件
	for i := range 5 {
		eb.EmitProgress(&types.ProgressTextChunkEvent{Step: i, Delta: "test"})
	}

	// 获取 cursor 3 之后的事件
	events := eb.GetTimelineSince(3)
	if len(events) != 2 {
		t.Errorf("expected 2 events after cursor 3, got %d", len(events))
	}
}

// TestGetTimelineFiltered 测试过滤获取时间线
func TestGetTimelineFiltered(t *testing.T) {