diff --git a/rtmp/rtmp.go b/rtmp/rtmp.go index c79f8352..56c9a653 100644 --- a/rtmp/rtmp.go +++ b/rtmp/rtmp.go @@ -260,7 +260,7 @@ func handlePacket(s *Session, pkt *packet) error { case packetTypeClientBW: s.clientBW = amf.DecodeInt32(pkt.body[:4]) if pkt.bodySize > 4 { - s.clientBW2 = uint32(pkt.body[4]) + s.clientBW2 = pkt.body[4] } else { s.clientBW2 = 0xff } diff --git a/rtmp/session.go b/rtmp/session.go index 766522d5..8da2626b 100644 --- a/rtmp/session.go +++ b/rtmp/session.go @@ -51,7 +51,7 @@ type Session struct { streamID int32 serverBW uint32 clientBW uint32 - clientBW2 uint32 + clientBW2 uint8 isPlaying bool numInvokes int32 methodCalls []method