Fix exiting loop
This commit is contained in:
parent
899a863131
commit
25efb3152b
1 changed files with 1 additions and 1 deletions
|
|
@ -326,7 +326,7 @@ func (s *server) srtlogListener(ctx context.Context) {
|
|||
for {
|
||||
select {
|
||||
case <-ctx.Done():
|
||||
break
|
||||
return
|
||||
case l := <-s.srtlogger.Listen():
|
||||
s.srtlogLock.Lock()
|
||||
if buf := s.srtlog[l.Topic]; buf == nil {
|
||||
|
|
|
|||
Loading…
Reference in a new issue