diff --git a/pkg/rtmp/amf0.go b/pkg/rtmp/amf0.go index 8823485..a77b513 100644 --- a/pkg/rtmp/amf0.go +++ b/pkg/rtmp/amf0.go @@ -304,6 +304,12 @@ func (amf0) ReadObject(b []byte) (ObjectPairArray, int, error) { } ops = append(ops, ObjectPair{k, v}) index += l + case Amf0TypeMarkerNull: + l, err := Amf0.ReadNull(b[index:]) + if err != nil { + return nil, 0, err + } + index += l default: nazalog.Panicf("unknown type. vt=%d", vt) } @@ -357,6 +363,12 @@ func (amf0) ReadArray(b []byte) (ObjectPairArray, int, error) { } ops = append(ops, ObjectPair{k, v}) index += l + case Amf0TypeMarkerNull: + l, err := Amf0.ReadNull(b[index:]) + if err != nil { + return nil, 0, err + } + index += l default: nazalog.Panicf("unknown type. vt=%d", vt) }