Skip to content

Commit bc6b7a5

Browse files
committed
fix: add rtcp consumer
1 parent 44a6bb4 commit bc6b7a5

File tree

1 file changed

+11
-1
lines changed

1 file changed

+11
-1
lines changed

internal/transcode.go

Lines changed: 11 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -110,10 +110,20 @@ func TranscodePeerConnection(pc *webrtc.PeerConnection) error {
110110
return
111111
}
112112

113-
if _, err := pc.AddTrack(tl); err != nil {
113+
rtpSender, err := pc.AddTrack(tl)
114+
if err != nil {
114115
zap.L().Error("could not add track", zap.Error(err))
115116
return
116117
}
118+
119+
go func() {
120+
buf := make([]byte, 1500)
121+
for {
122+
if _, _, err := rtpSender.Read(buf); err != nil {
123+
return
124+
}
125+
}
126+
}()
117127

118128
bin, err := NewPipeline(tr.Codec())
119129
if err != nil {

0 commit comments

Comments
 (0)