Remove chunks from MSE
This commit is contained in:
@@ -9,8 +9,6 @@ import (
|
|||||||
"strings"
|
"strings"
|
||||||
)
|
)
|
||||||
|
|
||||||
const packetSize = 1400
|
|
||||||
|
|
||||||
func handlerWSMSE(tr *api.Transport, msg *api.Message) error {
|
func handlerWSMSE(tr *api.Transport, msg *api.Message) error {
|
||||||
src := tr.Request.URL.Query().Get("src")
|
src := tr.Request.URL.Query().Get("src")
|
||||||
stream := streams.GetOrNew(src)
|
stream := streams.GetOrNew(src)
|
||||||
@@ -30,10 +28,6 @@ func handlerWSMSE(tr *api.Transport, msg *api.Message) error {
|
|||||||
|
|
||||||
cons.Listen(func(msg interface{}) {
|
cons.Listen(func(msg interface{}) {
|
||||||
if data, ok := msg.([]byte); ok {
|
if data, ok := msg.([]byte); ok {
|
||||||
for len(data) > packetSize {
|
|
||||||
tr.Write(data[:packetSize])
|
|
||||||
data = data[packetSize:]
|
|
||||||
}
|
|
||||||
tr.Write(data)
|
tr.Write(data)
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
|
|||||||
Reference in New Issue
Block a user