Implementation for Watch
| 1186 | |
| 1187 | // Implementation for Watch |
| 1188 | type watcher struct { |
| 1189 | mu sync.Mutex |
| 1190 | updates chan KeyValueEntry |
| 1191 | sub *nats.Subscription |
| 1192 | initDone bool |
| 1193 | initPending uint64 |
| 1194 | received uint64 |
| 1195 | } |
| 1196 | |
| 1197 | // Updates returns the interior channel. |
| 1198 | func (w *watcher) Updates() <-chan KeyValueEntry { |
nothing calls this directly
no outgoing calls
no test coverage detected