jeans/core
jeans/core
1
0
Fork 0
mirror of https://github.com/home-assistant/core.git synced 2025-07-21 12:17:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

Bugfix mqtt paho client to speend time (#6266)

Browse Source
This commit is contained in:
Pascal Vizeli 2017-02-27 00:28:54 +01:00 committed by Paulus Schoutsen
parent d487960ad8
commit 3d26ac3323
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
homeassistant/components/mqtt/__init__.py
View File

@ -436,6 +436,7 @@ class MQTT(object):
with (yield from self._paho_lock): with (yield from self._paho_lock):
yield from self.hass.loop.run_in_executor( yield from self.hass.loop.run_in_executor(
None, self._mqttc.publish, topic, payload, qos, retain) None, self._mqttc.publish, topic, payload, qos, retain)
yield from asyncio.sleep(0, loop=self.hass.loop)
@asyncio.coroutine @asyncio.coroutine
def async_connect(self): def async_connect(self):
@ -486,6 +487,7 @@ class MQTT(object):
with (yield from self._paho_lock): with (yield from self._paho_lock):
result, mid = yield from self.hass.loop.run_in_executor( result, mid = yield from self.hass.loop.run_in_executor(
None, self._mqttc.subscribe, topic, qos) None, self._mqttc.subscribe, topic, qos)
yield from asyncio.sleep(0, loop=self.hass.loop)
_raise_on_error(result) _raise_on_error(result)
self.progress[mid] = topic self.progress[mid] = topic