forked from bluenviron/gohlslib
-
Notifications
You must be signed in to change notification settings - Fork 0
/
main.go
62 lines (50 loc) · 1.46 KB
/
main.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
package main
import (
"log"
"time"
"github.com/bluenviron/gohlslib"
"github.com/bluenviron/gohlslib/pkg/codecs"
)
// This example shows how to read a HLS stream.
func main() {
// setup client
var c *gohlslib.Client
c = &gohlslib.Client{
URI: "https://myserver/mystream/index.m3u8",
// set a callback that is called when tracks are parsed
OnTracks: func(tracks []*gohlslib.Track) error {
for _, track := range tracks {
ttrack := track
log.Printf("detected track with codec %T\n", track.Codec)
// set a callback that is called when data is received
switch track.Codec.(type) {
case *codecs.AV1:
c.OnDataAV1(track, func(pts time.Duration, tu [][]byte) {
log.Printf("received data from track %T, pts = %v", ttrack, pts)
})
case *codecs.H264, *codecs.H265:
c.OnDataH26x(track, func(pts time.Duration, dts time.Duration, au [][]byte) {
log.Printf("received data from track %T, pts = %v", ttrack, pts)
})
case *codecs.MPEG4Audio:
c.OnDataMPEG4Audio(track, func(pts time.Duration, aus [][]byte) {
log.Printf("received data from track %T, pts = %v", ttrack, pts)
})
case *codecs.Opus:
c.OnDataOpus(track, func(pts time.Duration, packets [][]byte) {
log.Printf("received data from track %T, pts = %v", ttrack, pts)
})
}
}
return nil
},
}
// start reading
err := c.Start()
if err != nil {
panic(err)
}
defer c.Close()
// wait for a fatal error
panic(<-c.Wait())
}