diff --git a/main.go b/main.go index dcabdf0..cecb854 100644 --- a/main.go +++ b/main.go @@ -60,7 +60,6 @@ type WebRTCConfig struct { config.Subscribe ICEServers []ICEServer PublicIP []string - PublicPort uint16 Port string `default:"tcp:9000"` PLI time.Duration `default:"2s"` // 视频流丢包后,发送PLI请求 m MediaEngine @@ -137,9 +136,6 @@ func (conf *WebRTCConfig) Play_(w http.ResponseWriter, r *http.Request) { suber.OnICECandidate(func(ice *ICECandidate) { if ice != nil { suber.Info(ice.ToJSON().Candidate) - if conf.PublicPort != 0 { - ice.Port = conf.PublicPort - } } }) if err = suber.SetRemoteDescription(SessionDescription{Type: SDPTypeOffer, SDP: suber.SDP}); err != nil { diff --git a/subscriber.go b/subscriber.go index 9b3f8b9..3e92d74 100644 --- a/subscriber.go +++ b/subscriber.go @@ -120,13 +120,13 @@ func (suber *WebRTCSubscriber) OnEvent(event any) { suber.Trace("video rtp", zap.Any("packet", v.Packet.Header)) suber.videoTrack.WriteRTP(v.Packet) } else if suber.DC != nil { - suber.sendAvByDatachannel(9, &suber.VideoReader) + suber.sendAvByDatachannel(9, suber.VideoReader) } case AudioRTP: if suber.audioTrack != nil { suber.audioTrack.WriteRTP(v.Packet) } else if suber.DC != nil { - suber.sendAvByDatachannel(8, &suber.AudioReader) + suber.sendAvByDatachannel(8, suber.AudioReader) } case ISubscriber: suber.OnConnectionStateChange(func(pcs PeerConnectionState) {