diff --git a/pkg/magic/producer.go b/pkg/magic/producer.go index 90a4b2a0..46002807 100644 --- a/pkg/magic/producer.go +++ b/pkg/magic/producer.go @@ -12,6 +12,7 @@ import ( "github.com/AlexxIT/go2rtc/pkg/magic/bitstream" "github.com/AlexxIT/go2rtc/pkg/magic/mjpeg" "github.com/AlexxIT/go2rtc/pkg/mpegts" + "github.com/AlexxIT/go2rtc/pkg/multipart" ) func Open(r io.Reader) (core.Producer, error) { @@ -32,6 +33,9 @@ func Open(r io.Reader) (core.Producer, error) { case bytes.HasPrefix(b, []byte(flv.Signature)): return flv.Open(rd) + case bytes.HasPrefix(b, []byte("--")): + return multipart.Open(rd) + case b[0] == mpegts.SyncByte: return mpegts.Open(rd) }