fix bug that prevented multiple readers from accessing the same stream (

#2281) (#2282)
bluenviron · Sep 1, 2023 · ffa3442 · ffa3442
1 parent 966bec8
commit ffa3442
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 4 deletions.
diff --git a/internal/core/webrtc_outgoing_track.go b/internal/core/webrtc_outgoing_track.go
@@ -363,7 +363,5 @@ func (t *webRTCOutgoingTrack) start(
 		}
 	}()
 
-	stream.AddReader(writer, t.media, t.format, func(u unit.Unit) error {
-		return t.cb(u)
-	})
+	stream.AddReader(writer, t.media, t.format, t.cb)
 }
diff --git a/internal/stream/stream_format.go b/internal/stream/stream_format.go
@@ -80,8 +80,9 @@ func (sf *streamFormat) writeUnit(s *Stream, medi *description.Media, u unit.Uni
 	}
 
 	for writer, cb := range sf.readers {
+		ccb := cb
 		writer.Push(func() error {
-			return cb(u)
+			return ccb(u)
 		})
 	}
 }