()
| 264 | } |
| 265 | |
| 266 | func (e *Engine) start() { |
| 267 | defer e.wg.Done() |
| 268 | for { |
| 269 | select { |
| 270 | case <-e.closeCh: |
| 271 | return |
| 272 | case re, ok := <-e.eventCh: |
| 273 | if !ok { |
| 274 | return |
| 275 | } |
| 276 | e.applyEvents(re) |
| 277 | } |
| 278 | } |
| 279 | } |
| 280 | |
| 281 | func (e *Engine) forwardEvents(ctx context.Context, root string, w *fsWatcher) { |
| 282 | defer e.wg.Done() |
no test coverage detected