NewTicker returns a Source that emits e every d.
(d time.Duration, e event.GenericEvent, h handler.EventHandler)
| 25 | |
| 26 | // NewTicker returns a Source that emits e every d. |
| 27 | func NewTicker(d time.Duration, e event.GenericEvent, |
| 28 | h handler.EventHandler) source.Source { |
| 29 | return &ticker{Duration: d, GenericEvent: e, Handler: h} |
| 30 | } |
| 31 | |
| 32 | // NewTickerImmediate returns a Source that emits e at start and every d. |
| 33 | func NewTickerImmediate(d time.Duration, e event.GenericEvent, |