(dur time.Duration)
| 296 | } |
| 297 | |
| 298 | func (r *Stream) resetTimer(dur time.Duration) { |
| 299 | r.Debug("reset timer", zap.Duration("timeout", dur)) |
| 300 | r.timeout.Reset(dur) |
| 301 | } |
| 302 | |
| 303 | func (r *Stream) action(action StreamAction) (ok bool) { |
| 304 | var event StateEvent |