CodingPirates/pyscrlink
1
0
Fork 0
mirror of https://github.com/kawasaki/pyscrlink.git synced 2025-09-06 17:50:20 +02:00
Code Issues Packages Projects Releases Wiki Activity

BLESession.notify: Send out notifications at once to avoid interruption

Browse Source
This commit is contained in:
MDE
2020-02-08 22:33:22 +01:00
committed by Shin'ichiro Kawasaki
parent ba8eba4800
commit 2c7a10f848
1 changed files with 9 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
scratch_link.py
View File

@@ -95,20 +95,22 @@ class Session():
Notify BT/BLE device events to scratch.
"""
logger.debug("start to notify")
# flush notification queue
# merge all notifications queued
notifications = []
while not self.notification_queue.empty():
method, params = self.notification_queue.get()
self._send_notification(method, params)
notifications.append(self._build_notification(method, params))
# send merged notifications
future = asyncio.run_coroutine_threadsafe(
self.websocket.send('\n'.join(notifications)), self.loop)
result = future.result()
def _send_notification(self, method, params):
def _build_notification(self, method, params):
jsonn = { 'jsonrpc': "2.0", 'method': method }
jsonn['params'] = params
notification = json.dumps(jsonn)
logger.debug(f"notification: {notification}")
future = asyncio.run_coroutine_threadsafe(
self.websocket.send(notification), self.loop)
result = future.result()
return notification
async def handle(self):
logger.debug("start session hanlder")