Skip to content

Commit 44a1948

Browse files
committed
fix: consume rtcp
1 parent 1682309 commit 44a1948

File tree

1 file changed

+11
-1
lines changed

1 file changed

+11
-1
lines changed

pkg/client.go

Lines changed: 11 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -153,9 +153,19 @@ func NewTranscoderAPIClient(conn *grpc.ClientConn) (*TranscoderClient, error) {
153153
}
154154

155155
func (c *TranscoderClient) Transcode(tl webrtc.TrackLocal) (*webrtc.TrackRemote, error) {
156-
if _, err := c.peerConnection.AddTrack(tl); err != nil {
156+
rtpSender, err := c.peerConnection.AddTrack(tl)
157+
if err != nil {
157158
return nil, err
158159
}
160+
161+
go func() {
162+
buf := make([]byte, 1500)
163+
for {
164+
if _, _, err := rtpSender.Read(buf); err != nil {
165+
return
166+
}
167+
}
168+
}()
159169

160170
c.Lock()
161171
promise := make(chan *webrtc.TrackRemote)

0 commit comments

Comments
 (0)