Commit 4de29530 authored by Juliusz Chroboczek's avatar Juliusz Chroboczek

Fix incorrect closure in pushConnsAction.

This was causing us to lose connections.
parent f7048e4d
...@@ -819,7 +819,7 @@ func clientLoop(c *webClient, ws *websocket.Conn) error { ...@@ -819,7 +819,7 @@ func clientLoop(c *webClient, ws *websocket.Conn) error {
for i, t := range tracks { for i, t := range tracks {
ts[i] = t ts[i] = t
} }
go func() { go func(u *rtpUpConnection, ts []conn.UpTrack) {
err := a.client.PushConn( err := a.client.PushConn(
g, u.id, u, ts, u.label, g, u.id, u, ts, u.label,
) )
...@@ -829,7 +829,7 @@ func clientLoop(c *webClient, ws *websocket.Conn) error { ...@@ -829,7 +829,7 @@ func clientLoop(c *webClient, ws *websocket.Conn) error {
err, err,
) )
} }
}() }(u, ts)
} }
case connectionFailedAction: case connectionFailedAction:
if down := getDownConn(c, a.id); down != nil { if down := getDownConn(c, a.id); down != nil {
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment