chore(bug): initialize the atomic variable (#1889)

mangalaman93 · web-flow · commit ebd6fed79df8 · 2023-02-28T14:24:57.000-06:00
diff --git a/publisher.go b/publisher.go
@@ -129,6 +129,7 @@ func (p *publisher) newSubscriber(c *z.Closer, matches []pb.Match) (subscriber,
 		matches:   matches,
 		sendCh:    ch,
 		subCloser: c,
+		active:    new(atomic.Uint64),
 	}
 	s.active.Store(1)
 

Original file line number	Diff line number	Diff line change
`@@ -129,6 +129,7 @@ func (p publisher) newSubscriber(c z.Closer, matches []pb.Match) (subscriber,`
`129`	`129`	`matches: matches,`
`130`	`130`	`sendCh: ch,`
`131`	`131`	`subCloser: c,`
	`132`	`+ active: new(atomic.Uint64),`
`132`	`133`	`}`
`133`	`134`	`s.active.Store(1)`
`134`	`135`