Code refactoring
This commit is contained in:
+5
-6
@@ -87,7 +87,10 @@ func RTPPay(mtu uint16) streamer.WrapperFunc {
|
|||||||
|
|
||||||
return func(push streamer.WriterFunc) streamer.WriterFunc {
|
return func(push streamer.WriterFunc) streamer.WriterFunc {
|
||||||
return func(packet *rtp.Packet) error {
|
return func(packet *rtp.Packet) error {
|
||||||
if packet.Version == RTPPacketVersionAVC {
|
if packet.Version != RTPPacketVersionAVC {
|
||||||
|
return push(packet)
|
||||||
|
}
|
||||||
|
|
||||||
payloads := payloader.Payload(mtu, packet.Payload)
|
payloads := payloader.Payload(mtu, packet.Payload)
|
||||||
last := len(payloads) - 1
|
last := len(payloads) - 1
|
||||||
for i, payload := range payloads {
|
for i, payload := range payloads {
|
||||||
@@ -95,10 +98,8 @@ func RTPPay(mtu uint16) streamer.WrapperFunc {
|
|||||||
Header: rtp.Header{
|
Header: rtp.Header{
|
||||||
Version: 2,
|
Version: 2,
|
||||||
Marker: i == last,
|
Marker: i == last,
|
||||||
//PayloadType: packet.PayloadType,
|
|
||||||
SequenceNumber: sequencer.NextSequenceNumber(),
|
SequenceNumber: sequencer.NextSequenceNumber(),
|
||||||
Timestamp: packet.Timestamp,
|
Timestamp: packet.Timestamp,
|
||||||
//SSRC: packet.SSRC,
|
|
||||||
},
|
},
|
||||||
Payload: payload,
|
Payload: payload,
|
||||||
}
|
}
|
||||||
@@ -106,10 +107,8 @@ func RTPPay(mtu uint16) streamer.WrapperFunc {
|
|||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
return push(packet)
|
return nil
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user