Fix HLS after big refactoring
This commit is contained in:
+2
-1
@@ -29,6 +29,7 @@ func Init() {
|
|||||||
|
|
||||||
type Consumer interface {
|
type Consumer interface {
|
||||||
core.Consumer
|
core.Consumer
|
||||||
|
Listen(f core.EventFunc)
|
||||||
Init() ([]byte, error)
|
Init() ([]byte, error)
|
||||||
MimeCodecs() string
|
MimeCodecs() string
|
||||||
Start()
|
Start()
|
||||||
@@ -84,7 +85,7 @@ func handlerStream(w http.ResponseWriter, r *http.Request) {
|
|||||||
|
|
||||||
session := &Session{cons: cons}
|
session := &Session{cons: cons}
|
||||||
|
|
||||||
cons.(any).(*core.Listener).Listen(func(msg any) {
|
cons.Listen(func(msg any) {
|
||||||
if data, ok := msg.([]byte); ok {
|
if data, ok := msg.([]byte); ok {
|
||||||
session.mu.Lock()
|
session.mu.Lock()
|
||||||
session.segment = append(session.segment, data...)
|
session.segment = append(session.segment, data...)
|
||||||
|
|||||||
Reference in New Issue
Block a user