diff --git a/internal/core/webrtc_conn.go b/internal/core/webrtc_conn.go index abd28c1c..d1ac421c 100644 --- a/internal/core/webrtc_conn.go +++ b/internal/core/webrtc_conn.go @@ -349,9 +349,10 @@ outer: writeError := make(chan error) for _, track := range tracks { + ctrack := track res.stream.readerAdd(c, track.media, track.format, func(dat data) { ringBuffer.Push(func() { - track.cb(dat, ctx, writeError) + ctrack.cb(dat, ctx, writeError) }) }) } diff --git a/internal/core/webrtc_index.html b/internal/core/webrtc_index.html index 30725641..a99afa05 100644 --- a/internal/core/webrtc_index.html +++ b/internal/core/webrtc_index.html @@ -93,7 +93,7 @@ class Receiver { this.pc.ontrack = (evt) => { console.log("new track " + evt.track.kind); - document.getElementById("video").srcObject = new MediaStream([evt.track]); + document.getElementById("video").srcObject = evt.streams[0]; }; const direction = "sendrecv";