diff --git a/subscriber.go b/subscriber.go index 0753eff..c329890 100644 --- a/subscriber.go +++ b/subscriber.go @@ -73,7 +73,7 @@ func (suber *WebRTCSubscriber) OnEvent(event any) { suber.Info("Connection State has changed:" + pcs.String()) switch pcs { case PeerConnectionStateConnected: - go suber.PlayBlock() + go suber.PlayRaw() case PeerConnectionStateDisconnected, PeerConnectionStateFailed: suber.Stop() suber.PeerConnection.Close()