Merge pull request #3290 from tomiwu/main

Fix for decoding a PES packet with a header, when the DTS (Decoding Timestamp) is unavailable.
typelevel · Aug 30, 2023 · 655aabe · 655aabe
2 parents 73429d2 + bc75cb6
commit 655aabe
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/protocols/shared/src/main/scala/fs2/protocols/mpeg/PesPacketHeader.scala b/protocols/shared/src/main/scala/fs2/protocols/mpeg/PesPacketHeader.scala
@@ -185,7 +185,10 @@ object PesPacketHeader {
       ("flags" | Codec[Flags]).flatPrepend { flags =>
         variableSizeBytes(
           uint8,
-          ("pts" | conditional(flags.ptsFlag, tsCodec(bin"0011"))) ::
+          ("pts" | conditional(
+            flags.ptsFlag,
+            if (flags.dtsFlag) tsCodec(bin"0011") else tsCodec(bin"0010")
+          )) ::
             ("dts" | conditional(flags.dtsFlag, tsCodec(bin"0001"))) ::
             ("escr" | conditional(flags.escrFlag, escrCodec)) ::
             ("es_rate" | conditional(flags.esRateFlag, ignore(1) ~> uint(22) <~ ignore(1))) ::