apps/plugin-webrtc
1
0
Fork 0
mirror of https://github.com/Monibuca/plugin-webrtc.git synced 2025-10-16 11:50:42 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

feat: add stop reason

Browse Source
This commit is contained in:
langhuihui
2023-08-06 15:09:20 +08:00
parent 261851f7f7
commit d39958089a
5 changed files with 39 additions and 34 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
batcher.go
View File

@@ -2,6 +2,7 @@ package webrtc
import (
"encoding/json"
"fmt"
. "github.com/pion/webrtc/v3"
"go.uber.org/zap"
@@ -72,11 +73,12 @@ func (suber *WebRTCBatcher) Start() (err error) {
case PeerConnectionStateConnected:
case PeerConnectionStateDisconnected, PeerConnectionStateFailed:
zr := zap.String("reason", pcs.String())
for _, sub := range suber.subscribers {
go sub.Stop()
go sub.Stop(zr)
}
if suber.Publisher.Stream != nil {
suber.Publisher.Stop()
suber.Publisher.Stop(zr)
}
suber.PeerConnection.Close()
}
@@ -110,8 +112,9 @@ func (suber *WebRTCBatcher) Signal(msg DataChannelMessage) {
WebRTCPlugin.Error("Signal SetRemoteDescription", zap.Error(err))
return
}
for _, streamPath := range s.StreamList {
for i, streamPath := range s.StreamList {
sub := &WebRTCBatchSubscriber{}
sub.ID = fmt.Sprintf("%s_%d", suber.ID, i)
sub.WebRTCIO = suber.WebRTCIO
if err = WebRTCPlugin.SubscribeExist(streamPath, sub); err == nil {
suber.subscribers = append(suber.subscribers, sub)