(_ context.Context)
| 29 | armed chan struct{} // Execute → Wait handoff, buffered(1): remembers one pending arm |
| 30 | } |
| 31 | |
| 32 | func NewDelay(id string, d time.Duration) *Delay { |
| 33 | return &Delay{ |
| 34 | TriggerNode: engine.NewTriggerNode(id), |
| 35 | duration: d, |
| 36 | armed: make(chan struct{}, 1), |
| 37 | } |
no outgoing calls