Close unsubscribes and stops the reconcile ticker.
()
| 131 | |
| 132 | // Close unsubscribes and stops the reconcile ticker. |
| 133 | func (m *SyncedMap[K, V]) Close() error { |
| 134 | if m.cancel != nil { |
| 135 | m.cancel() |
| 136 | } |
| 137 | m.wg.Wait() |
| 138 | if m.sub != nil { |
| 139 | return m.sub.Unsubscribe() |
| 140 | } |
| 141 | return nil |
| 142 | } |
| 143 | |
| 144 | // Set updates the value locally, writes through the Store, then broadcasts. |
| 145 | // Per the data-flow contract the Store write happens under the lock so memory and |
nothing calls this directly
no test coverage detected