diff --git a/srt/srt.go b/srt/srt.go
index 9111f6fa..bd149a05 100644
--- a/srt/srt.go
+++ b/srt/srt.go
@@ -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 {