|
@@ -66,6 +66,8 @@ var action = func(ctx *cli.Context) error {
|
|
|
}
|
|
|
}()
|
|
|
|
|
|
+ // usually HLS stream segments have 2s length;
|
|
|
+ //
|
|
|
if downloader, err = download.NewHLS(p.HLSStream, time.Second*2); err != nil {
|
|
|
return err
|
|
|
}
|
|
@@ -78,8 +80,6 @@ var action = func(ctx *cli.Context) error {
|
|
|
return err
|
|
|
case buff := <-chStream:
|
|
|
if buff == nil {
|
|
|
- close(chStream)
|
|
|
-
|
|
|
go func() {
|
|
|
<-time.After(time.Second * 5)
|
|
|
chStream = downloader.Start()
|