We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 67aa107 commit b4e27dfCopy full SHA for b4e27df
server/jetstream.go
@@ -1556,12 +1556,16 @@ func (a *Account) filteredStreams(filter string) []*stream {
1556
var msets []*stream
1557
for _, mset := range jsa.streams {
1558
if filter != _EMPTY_ {
1559
- for _, subj := range mset.cfg.Subjects {
1560
- if SubjectsCollide(filter, subj) {
1561
- msets = append(msets, mset)
1562
- break
+ func() {
+ mset.cfgMu.RLock()
+ defer mset.cfgMu.RUnlock()
+ for _, subj := range mset.cfg.Subjects {
1563
+ if SubjectsCollide(filter, subj) {
1564
+ msets = append(msets, mset)
1565
+ break
1566
+ }
1567
}
- }
1568
+ }()
1569
} else {
1570
msets = append(msets, mset)
1571
0 commit comments