From 79b48f600654333ecc6442ee8c50f184c3a2bc3d Mon Sep 17 00:00:00 2001 From: Philipp Spitzer Date: Thu, 9 Jul 2020 22:18:06 +0200 Subject: [PATCH] Replace blocking function calls with awaits. --- lagarde.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) 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) -- 2.39.5