Bugfix mqtt paho client to speend time (#6266)

This commit is contained in:
Pascal Vizeli 2017-02-27 00:28:54 +01:00 committed by Paulus Schoutsen
parent d789de9ea2
commit 31ddcc6278

View File

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