Method DistributeToModelPipelines

ai-provider/local/executor.go:194–208

DistributeToModelPipelines 仅将消息分发给指定模型的管道

(model string, msg PullMessage)

// DistributeToModelPipelines 仅将消息分发给指定模型的管道
func (e *AsyncExecutor) DistributeToModelPipelines(model string, msg PullMessage) {
	e.mu.Lock()
	defer e.mu.Unlock()
	pipelines, ok := e.pipelines[model]
	if !ok {
		return
	}
	for _, pipeline := range pipelines.List() {
		select {
		case pipeline.channel <- msg:
		default:
			// 如果管道已满，跳过
		}
	}
}

type PullCallback func(msg PullMessage) error