diff --git a/pkg/rtc/participant.go b/pkg/rtc/participant.go index bab1aa124..bfa10878b 100644 --- a/pkg/rtc/participant.go +++ b/pkg/rtc/participant.go @@ -431,6 +431,8 @@ func (p *ParticipantImpl) OnTrackPublished(callback func(types.LocalParticipant, } func (p *ParticipantImpl) OnStateChange(callback func(p types.LocalParticipant, oldState livekit.ParticipantInfo_State)) { + p.lock.Lock() + defer p.lock.Unlock() p.onStateChange = callback }