(msg *livekit.ServerMessage)
| 154 | } |
| 155 | |
| 156 | func (c *WSSignalConnection) WriteServerMessage(msg *livekit.ServerMessage) (int, error) { |
| 157 | var msgType int |
| 158 | var payload []byte |
| 159 | var err error |
| 160 | |
| 161 | c.mu.Lock() |
| 162 | defer c.mu.Unlock() |
| 163 | |
| 164 | if c.useJSON { |
| 165 | msgType = websocket.TextMessage |
| 166 | payload, err = protojson.Marshal(msg) |
| 167 | } else { |
| 168 | msgType = websocket.BinaryMessage |
| 169 | payload, err = proto.Marshal(msg) |
| 170 | } |
| 171 | if err != nil { |
| 172 | return 0, err |
| 173 | } |
| 174 | |
| 175 | return len(payload), c.conn.WriteMessage(msgType, payload) |
| 176 | } |
| 177 | |
| 178 | func (c *WSSignalConnection) pingWorker() { |
| 179 | ticker := time.NewTicker(pingFrequency) |
nothing calls this directly
no test coverage detected