(observer taskRunEnqueuedObserver)
| 439 | } |
| 440 | |
| 441 | func (n *hooksNotifier) AddTaskRunEnqueuedObserver(observer taskRunEnqueuedObserver) { |
| 442 | if n == nil || observer == nil { |
| 443 | return |
| 444 | } |
| 445 | n.mu.Lock() |
| 446 | defer n.mu.Unlock() |
| 447 | n.taskRunEnqueuedHooks = append(n.taskRunEnqueuedHooks, observer) |
| 448 | } |
| 449 | |
| 450 | func (n *hooksNotifier) taskRunEnqueuedObservers() []taskRunEnqueuedObserver { |
| 451 | if n == nil { |