diff --git a/internal/recorder/streamer.go b/internal/recorder/streamer.go index a6eab4b..9ffbff1 100644 --- a/internal/recorder/streamer.go +++ b/internal/recorder/streamer.go @@ -466,8 +466,8 @@ func (st *Streamer) attachPendingListeners(sess *streamSession) { // CloseAll finalises all sessions and stops the worker goroutine. func (st *Streamer) RuntimeInfoBySignalID() map[int64]RuntimeSignalInfo { - st.mu.RLock() - defer st.mu.RUnlock() + st.mu.Lock() + defer st.mu.Unlock() out := make(map[int64]RuntimeSignalInfo, len(st.sessions)) for _, sess := range st.sessions { out[sess.signalID] = RuntimeSignalInfo{