NewWatcher - Creates a new Watcher
(database *db.Memory)
| 15 | |
| 16 | // NewWatcher - Creates a new Watcher |
| 17 | func NewWatcher(database *db.Memory) *Watch { |
| 18 | return &Watch{ |
| 19 | database: database, |
| 20 | } |
| 21 | } |
| 22 | |
| 23 | // Watch - Watches for changes in the repository. |
| 24 | func (r *Watch) Watch(_ context.Context, _, _ string) (<-chan *base.DataChanges, <-chan error) { |