Method DrainPendingNotifications

agent/task_runtime.go:582–592

(scopeID string)

}

func (rt *AgentTaskRuntime) DrainPendingNotifications(scopeID string) []map[string]any {
	rt.mu.Lock()
	defer rt.mu.Unlock()
	notifications := rt.notifications[scopeID]
	rt.notifications[scopeID] = nil
	out := make([]map[string]any, 0, len(notifications))
	for _, notification := range notifications {
		out = append(out, notification.ToMessage())
	}
	return out
}

func (rt *AgentTaskRuntime) consumeMatchingNotifications(scopeID string, taskIDs []string) {
	rt.mu.Lock()