Check chan not closed before sending updates for memory loader (#1894)

* dont send on closed chan
2020-08-04 16:21:03 +01:00
parent 07fef9fd33
commit eee91ed976
1 changed files with 5 additions and 0 deletions
--- a/config/loader/memory/memory.go
+++ b/config/loader/memory/memory.go
@@ -176,6 +176,11 @@ func (m *memory) update() {
 			value:   vals.Get(w.path...),
 		}

+		select {
+		case <-w.exit:
+			continue
+		default:
+		}
 		select {
 		case w.updates <- uv:
 		default: