pass
def write(self, topic, key, msg):
pass
def write(self, topic, key, msg):
async def aiowrite(self, topic, key, msg, loop=None):
async def aiowrite(self, topic, key, msg, loop=None):
async def aioread(self, topic, loop=None, callback=None, aiocallback=None, **kwargs):
async def aioread(self, topic, loop=None, callback=None, aiocallback=None, **kwargs):