From: Philipp Spitzer <philipp@spitzer.priv.at>
Date: Thu, 9 Jul 2020 20:18:06 +0000 (+0200)
Subject: Replace blocking function calls with awaits.
X-Git-Url: https://git.toastfreeware.priv.at/toast/stream2beamer.git/commitdiff_plain/79b48f600654333ecc6442ee8c50f184c3a2bc3d

Replace blocking function calls with awaits.
---

diff --git a/lagarde.py b/lagarde.py
index 487b88c..75a81a7 100755
--- a/lagarde.py
+++ b/lagarde.py
@@ -118,13 +118,13 @@ class Lagarde:
                     rd = GstWebRTC.WebRTCSessionDescription.new(GstWebRTC.WebRTCSDPType.OFFER, sm)
                     gst_promise = Gst.Promise.new()
                     self.webrtcbin.emit('set-remote-description', rd, gst_promise)
-                    gst_promise.wait()
+                    await asyncio.get_event_loop().run_in_executor(None, gst_promise.wait)
                     self.sdp_offer = None
 
                     log.info('create-answer')
                     gst_promise = Gst.Promise.new()
                     self.webrtcbin.emit('create-answer', None, gst_promise)
-                    result = gst_promise.wait()
+                    result = await asyncio.get_event_loop().run_in_executor(None, gst_promise.wait)
                     assert result == Gst.PromiseResult.REPLIED
                     reply = gst_promise.get_reply()
                     answer = reply.get_value('answer')
@@ -145,7 +145,7 @@ class Lagarde:
                     })
                     gst_promise = Gst.Promise.new()
                     self.webrtcbin.emit('set-local-description', answer, gst_promise)
-                    gst_promise.wait()
+                    await asyncio.get_event_loop().run_in_executor(None, gst_promise.wait)
                     gst_promise.get_reply()
                     await self.websocket.send(sdp_answer_msg)