+import asyncio
from http import HTTPStatus
__author__ = "Alfonso Tierno <alfonso.tiernosepulveda@telefonica.com>"
def connect(self, config):
pass
- def write(self, msg):
+ def disconnect(self):
pass
- def read(self):
+ def write(self, topic, key, msg):
pass
- def disconnect(self):
+ def read(self, topic):
pass
+ async def aiowrite(self, topic, key, msg, loop):
+ pass
+
+ async def aioread(self, topic, loop):
+ pass