()
| 631 | } |
| 632 | |
| 633 | func (f *notifyFixture) closeWatcher() { |
| 634 | notify := f.notify |
| 635 | err := notify.Close() |
| 636 | if err != nil { |
| 637 | f.T().Fatal(err) |
| 638 | } |
| 639 | |
| 640 | // drain channels from watcher |
| 641 | go func() { |
| 642 | for range notify.Events() { |
| 643 | } |
| 644 | }() |
| 645 | |
| 646 | go func() { |
| 647 | for range notify.Errors() { |
| 648 | } |
| 649 | }() |
| 650 | } |
| 651 | |
| 652 | func (f *notifyFixture) tearDown() { |
| 653 | f.cancel() |