(r io.Reader)
| 187 | } |
| 188 | |
| 189 | func ReadTsPacket(r io.Reader) (packet MpegTsPacket, err error) { |
| 190 | lr := &io.LimitedReader{R: r, N: TS_PACKET_SIZE} |
| 191 | |
| 192 | // header |
| 193 | packet.Header, err = ReadTsHeader(lr) |
| 194 | if err != nil { |
| 195 | return |
| 196 | } |
| 197 | |
| 198 | // payload |
| 199 | packet.Payload = make([]byte, lr.N) |
| 200 | _, err = lr.Read(packet.Payload) |
| 201 | if err != nil { |
| 202 | return |
| 203 | } |
| 204 | |
| 205 | return |
| 206 | } |
| 207 | |
| 208 | func ReadTsHeader(r io.Reader) (header MpegTsHeader, err error) { |
| 209 | var h uint32 |
nothing calls this directly
no test coverage detected