From ea18475d3160cef3477c0b190bcf17f38739f5da Mon Sep 17 00:00:00 2001
From: Alexey Khit <alexey.khit@gmail.com>
Date: Mon, 7 Nov 2022 23:35:36 +0300
Subject: [PATCH] Split MSE data on packets

---
 cmd/mp4/mse.go | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/cmd/mp4/mse.go b/cmd/mp4/mse.go
index cbc202af..fb5fe5a4 100644
--- a/cmd/mp4/mse.go
+++ b/cmd/mp4/mse.go
@@ -9,6 +9,8 @@ import (
 
 const MsgTypeMSE = "mse" // fMP4
 
+const packetSize = 8192
+
 func handlerWS(ctx *api.Context, msg *streamer.Message) {
 	src := ctx.Request.URL.Query().Get("src")
 	stream := streams.GetOrNew(src)
@@ -22,6 +24,10 @@ func handlerWS(ctx *api.Context, msg *streamer.Message) {
 
 	cons.Listen(func(msg interface{}) {
 		if data, ok := msg.([]byte); ok {
+			for len(data) > packetSize {
+				ctx.Write(data[:packetSize])
+				data = data[packetSize:]
+			}
 			ctx.Write(data)
 		}
 	})