NewTickerImmediate returns a Source that emits e at start and every d.
(d time.Duration, e event.GenericEvent, h handler.EventHandler)
| 31 | |
| 32 | // NewTickerImmediate returns a Source that emits e at start and every d. |
| 33 | func NewTickerImmediate(d time.Duration, e event.GenericEvent, |
| 34 | h handler.EventHandler) source.Source { |
| 35 | return &ticker{Duration: d, GenericEvent: e, Handler: h, Immediate: true} |
| 36 | } |
| 37 | |
| 38 | func (t ticker) String() string { return "every " + t.Duration.String() } |
| 39 |