gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-02 03:38:42 -07:00
Code Issues Packages Projects Releases Wiki Activity

Update server/stream.go

Browse Source 
Pre-allocate

Co-authored-by: Neil <neil@nats.io>
This commit is contained in:
Derek Collison
2023-03-29 15:29:51 -07:00
committed by GitHub
parent c77872b519
commit 152b25c314
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
server/stream.go
View File

@@ -5114,7 +5114,7 @@ func (a *Account) RestoreStream(ncfg *StreamConfig, r io.Reader) (*stream, error
// Issue https://github.com/nats-io/nats-server/issues/3612
func (mset *stream) checkForOrphanMsgs() {
mset.mu.RLock()
var consumers []*consumer
consumers := make([]*consumer, 0, len(mset.consumers))
for _, o := range mset.consumers {
consumers = append(consumers, o)
}