Merge pull request #9 from bbc/webrtc_audio_channels_on_connection_cl…

…osed

webrtc to not error if the user closes their browser window

brave/outputs/webrtc.py

@@ -4,6 +4,7 @@
 import json
 import asyncio
 import gi
+import websockets
 gi.require_version('GstWebRTC', '1.0')
 from gi.repository import GstWebRTC
 gi.require_version('GstSdp', '1.0')
@@ -121,7 +122,14 @@ def on_message(bus, message):
                         }))
 
                     jsonData = json.dumps({'msg_type': 'volume', 'channels': channels, 'data': data})
-                    loop.create_task(ws.send(jsonData))
+
+                    async def _send_data():
+                        try:
+                            await ws.send(jsonData)
+                        except websockets.ConnectionClosed:
+                            pass
+
+                    loop.create_task(_send_data())
 
         self.pipeline.get_bus().add_signal_watch()
         self.pipeline.get_bus().connect('message::element', on_message)