Commitaf8d833

committed

Only close done channel when notifier is present

Signed-off-by: Danny Kopping <danny@coder.com>

1 parent6add98f commitaf8d833Copy full SHA for af8d833

File tree

-1

lines changed

-1

lines changed

Lines changed: 3 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -153,7 +153,9 @@ func (m *Manager) Run(ctx context.Context) {`
`153`	`153`	`// events, creating a notifier, and publishing bulk dispatch result updates to the store.`
`154`	`154`	`func (m*Manager)loop(ctx context.Context)error {`
`155`	`155`	`deferfunc() {`
`156`		`-close(m.done)`
	`156`	`+ifm.notifier!=nil {`
	`157`	`+close(m.done)`
	`158`	`+}`
`157`	`159`	`m.log.Info(context.Background(),"notification manager stopped")`
`158`	`160`	`}()`
`159`	`161`

Comments

(0)