Method Subscribe

pkg/events/bus.go:296–328

Subscribe 订阅指定通道的事件(返回channel)

(channels []types.AgentChannel, opts *types.SubscribeOptions)

// Subscribe 订阅指定通道的事件(返回channel)
func (eb *EventBus) Subscribe(channels []types.AgentChannel, opts *types.SubscribeOptions) <-chan types.AgentEventEnvelope {
	eb.mu.Lock()
	defer eb.mu.Unlock()

	// 创建缓冲channel(避免阻塞)
	ch := make(chan types.AgentEventEnvelope, 100)

	// 生成唯一订阅ID
	subID := generateSubID()

	// 注册到对应通道
	if len(channels) == 0 {
		channels = []types.AgentChannel{types.ChannelProgress, types.ChannelControl, types.ChannelMonitor}
	}

	for _, channel := range channels {
		switch channel {
		case types.ChannelProgress:
			eb.progressSubs[subID] = ch
		case types.ChannelControl:
			eb.controlSubs[subID] = ch
		case types.ChannelMonitor:
			eb.monitorSubs[subID] = ch
		}
	}

	// 如果指定了since,回放历史事件
	if opts != nil && opts.Since != nil {
		go eb.replay(ch, opts.Since, opts.Kinds, channels)
	}

	return ch
}

// Unsubscribe 取消订阅
func (eb *EventBus) Unsubscribe(ch <-chan types.AgentEventEnvelope) {