(scopeID string, taskIDs []string)
| 592 | } |
| 593 | |
| 594 | func (rt *AgentTaskRuntime) consumeMatchingNotifications(scopeID string, taskIDs []string) { |
| 595 | rt.mu.Lock() |
| 596 | defer rt.mu.Unlock() |
| 597 | rt.consumeMatchingNotificationsLocked(scopeID, taskIDs) |
| 598 | } |
| 599 | |
| 600 | func (rt *AgentTaskRuntime) consumeMatchingNotificationsLocked(scopeID string, taskIDs []string) { |
| 601 | if len(taskIDs) == 0 { |
no test coverage detected