| 5 | ) |
| 6 | |
| 7 | type watcher struct { |
| 8 | Updates chan *source.ChangeSet |
| 9 | Source *memory |
| 10 | Id string |
| 11 | } |
| 12 | |
| 13 | func (w *watcher) Next() (*source.ChangeSet, error) { |
| 14 | cs := <-w.Updates |
nothing calls this directly
no outgoing calls
no test coverage detected