Function TestUnsubscribeMultipleChannels

pkg/events/bus_test.go:327–347

TestUnsubscribeMultipleChannels 测试多通道取消订阅

(t *testing.T)

// TestUnsubscribeMultipleChannels 测试多通道取消订阅
func TestUnsubscribeMultipleChannels(t *testing.T) {
	eb := NewEventBus()
	defer eb.Close()

	// 订阅多个通道
	ch := eb.Subscribe([]types.AgentChannel{
		types.ChannelProgress,
		types.ChannelControl,
		types.ChannelMonitor,
	}, nil)

	eb.Unsubscribe(ch)

	eb.mu.RLock()
	totalSubs := len(eb.progressSubs) + len(eb.controlSubs) + len(eb.monitorSubs)
	eb.mu.RUnlock()

	if totalSubs != 0 {
		t.Errorf("expected 0 total subscribers, got %d", totalSubs)
	}
}